消息可以订阅,也可以发布消息.当你发布消息的时候,订阅你消息的’人’就会收到你的消息。
**(**``**pub.js) **
— 发布频道信息
1.引入redis模块var redis=require("redis")
2.连接redis(创建与redis的连接对象)— redis.createClient(port,域名)
var client = redis.createClient(63779,'localhost')
3.发布订阅 — .publish(‘订阅名称’,’发布的内容’) [在这里订阅的名称可以理解成一个’频道’]
`client.publish(‘testPublish’,’message from pub.js’)```
**(sub.js) **
— 订阅上面pub.js中发布的’频道’消息
1.引入redis模块**var redis=require("redis")
2.连接redis(创建与redis的连接对象)— redis.createClient(port,域名)
var client = redis.createClient(63779,'localhost')
3.订阅’频道’信息client.subscribe('testPublish')
4.监听消息到来事件 — .on(‘message’,callback(channel,msg))[ ‘message’表示当监听到订阅的频道发布信息时会触发后面的回调函数] client.on('message',(channel,msg)=>{
console.log('client on message,channel: ',channel,' message:',msg)
)