这篇文章给大家介绍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实现就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。