Redis的Pub/Sub如何以WebSockets为前端的类EventMachine实现

这篇文章给大家介绍redis 的 Pub/Sub如何以WebSockets为前端的类EventMachine实现，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

“专业、务实、高效、创新、把客户的事当成自己的事”是我们每一个人一直以来坚持追求的企业文化。 创新互联建站是您可以信赖的网站建设服务商、专业的互联网服务提供商! 专注于成都网站设计、成都网站制作、软件开发、设计服务业务。我们始终坚持以客户需求为导向，结合用户体验与视觉传达，提供有针对性的项目解决方案，提供专业性的建议，创新互联建站将不断地超越自我，追逐市场，引领市场！

EventMachine是一个Ruby的事件驱动网络库，一个以Redis的Pub/Sub机制为后端，以WebSockets为前端的类EventMachine实现。下面创新互联小编来讲解下Redis的Pub/Sub怎样以WebSockets为前端的类EventMachine实现?

Redis的Pub/Sub怎样以WebSockets为前端的类EventMachine实现

前端代码，创建Socket连接到本地8081端口，当有消息push过来的时候，将消息打印到指定的div里：

Redis的Pub/Sub怎样以WebSockets为前端的类EventMachine实现

后端代码：

require'redis'

require'em-websocket'

SOCKETS=[]

@redis=Redis.new(:host=>'127.0.0.1',:post=>6379)

#CreatingathreadfortheEMeventloop

Thread.newdo

EventMachine.rundo

#Createsawebsocketlistener

EventMachine::WebSocket.start(:host=>'0.0.0.0',:port=>8081)do|ws|

ws.onopendo

#WhensomeoneconnectsIwanttoaddthatsockettotheSOCKETSarraythat

#Iinstantiatedabove

puts'creatingsocket'

SOCKETS< 　　end 　　ws.onclosedo 　　#UponthecloseoftheconnectionIremoveitfrommylistofrunningsockets 　　puts'closingsocket' 　　SOCKETS.deletews 　　end 　　end 　　end 　　end 　　#Creatingathreadfortheredissubscribeblock 　　Thread.newdo 　　@redis.subscribe('ws')do|on| 　　#Whenamessageispublishedto'ws' 　　on.messagedo|chan,msg| 　　puts"sendingmessage:#{msg}" 　　#Sendoutthemessageoneachopensocket 　　SOCKETS.each{|s|s.sendmsg} 　　end 　　end 　　end 　　sleep 　　开启8081端口接受连接，同时连到Redis上订阅ws这个key的消息 　　当前后端都启动并连接上后，你就可以用如下代码往Redis的ws这个key上写消息，页面上就能看到push过来的消息了： 　　require'redis' 　　@redis=Redis.new(:host=>'127.0.0.1',:post=>6379)

@redis.publish'ws','Somethingwitty'

关于Redis 的 Pub/Sub如何以WebSockets为前端的类EventMachine实现就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。