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