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实现

　　后端代码：

　　requireredis

　　requireem-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

　　putscreatingsocket

SOCKETS< 　　end 　　ws.onclosedo 　　#UponthecloseoftheconnectionIremoveitfrommylistofrunningsockets 　　putsclosingsocket 　　SOCKETS.deletews 　　end 　　end 　　end 　　end 　　#Creatingathreadfortheredissubscribeblock 　　Thread.newdo 　　@redis.subscribe(ws)do|on| 　　#Whenamessageispublishedtows 　　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过来的消息了： 　　requireredis 　　@redis=Redis.new(:host=>127.0.0.1,:post=>6379)

@redis.publishws,Somethingwitty

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