这篇文章给大家介绍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实现就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
