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