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

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

“專(zhuān)業(yè)、務(wù)實(shí)、高效、創(chuàng)新、把客戶的事當(dāng)成自己的事”是我們每一個(gè)人一直以來(lái)堅(jiān)持追求的企業(yè)文化。 創(chuàng)新互聯(lián)建站是您可以信賴(lài)的網(wǎng)站建設(shè)服務(wù)商、專(zhuān)業(yè)的互聯(lián)網(wǎng)服務(wù)提供商! 專(zhuān)注于成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、軟件開(kāi)發(fā)、設(shè)計(jì)服務(wù)業(yè)務(wù)。我們始終堅(jiān)持以客戶需求為導(dǎo)向，結(jié)合用戶體驗(yàn)與視覺(jué)傳達(dá)，提供有針對(duì)性的項(xiàng)目解決方案，提供專(zhuān)業(yè)性的建議，創(chuàng)新互聯(lián)建站將不斷地超越自我，追逐市場(chǎng)，引領(lǐng)市場(chǎng)！

EventMachine是一個(gè)Ruby的事件驅(qū)動(dòng)網(wǎng)絡(luò)庫(kù)，一個(gè)以Redis的Pub/Sub機(jī)制為后端，以WebSockets為前端的類(lèi)EventMachine實(shí)現(xiàn)。下面創(chuàng)新互聯(lián)小編來(lái)講解下Redis的Pub/Sub怎樣以WebSockets為前端的類(lèi)EventMachine實(shí)現(xiàn)?

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

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

Redis的Pub/Sub怎樣以WebSockets為前端的類(lèi)EventMachine實(shí)現(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 　　開(kāi)啟8081端口接受連接，同時(shí)連到Redis上訂閱ws這個(gè)key的消息 　　當(dāng)前后端都啟動(dòng)并連接上后，你就可以用如下代碼往Redis的ws這個(gè)key上寫(xiě)消息，頁(yè)面上就能看到push過(guò)來(lái)的消息了： 　　require'redis' 　　@redis=Redis.new(:host=>'127.0.0.1',:post=>6379)

@redis.publish'ws','Somethingwitty'

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

當(dāng)前文章：Redis的Pub/Sub如何以WebSockets為前端的類(lèi)EventMachine實(shí)現(xiàn)
本文路徑：http://muchs.cn/article38/gjsppp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)建站、云服務(wù)器、小程序開(kāi)發(fā)、定制開(kāi)發(fā)、自適應(yīng)網(wǎng)站、品牌網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)