温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》
  • 首页 > 
  • 教程 > 
  • 数据库 > 
  • Redis 的 Pub/Sub如何以WebSockets为前端的类EventMachine实现

Redis 的 Pub/Sub如何以WebSockets为前端的类EventMachine实现

发布时间:2021-12-31 14:10:19 来源:亿速云 阅读:230 作者:柒染 栏目:数据库

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

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI