Redis 的 Pub/Sub如何以WebSockets為前端的類EventMachine實現(xiàn)

這篇文章給大家介紹Redis 的 Pub/Sub如何以WebSockets為前端的類EventMachine實現(xiàn)，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。

　　EventMachine是一個Ruby的事件驅(qū)動網(wǎng)絡(luò)庫，一個以Redis的Pub/Sub機制為后端，以WebSockets為前端的類EventMachine實現(xiàn)。下面億速云小編來講解下Redis的Pub/Sub怎樣以WebSockets為前端的類EventMachine實現(xiàn)?

　　Redis的Pub/Sub怎樣以WebSockets為前端的類EventMachine實現(xiàn)

　　前端代碼，創(chuàng)建Socket連接到本地8081端口，當(dāng)有消息push過來的時候，將消息打印到指定的div里：

　　Redis的Pub/Sub怎樣以WebSockets為前端的類EventMachine實現(xiàn)

　　后端代碼：

　　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的消息 　　當(dāng)前后端都啟動并連接上后，你就可以用如下代碼往Redis的ws這個key上寫消息，頁面上就能看到push過來的消息了： 　　require'redis' 　　@redis=Redis.new(:host=>'127.0.0.1',:post=>6379)

　　@redis.publish'ws','Somethingwitty'

關(guān)于Redis 的 Pub/Sub如何以WebSockets為前端的類EventMachine實現(xiàn)就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。