luffy-echo
v1.0.23
Published
使用kafka进行广播,使用socket推送消息,使用echo接收消息
Readme
luffy-echo
获取socket消息
安装
npm install lufyy-echo使用
初始化
import {Echo} from 'luffy-echo';
window.Echo = new Echo('a82393d886a0e6ddfae5', {
host: 'ws://10.202.203.222:8091',
auth: {
url: 'http://tests.test/api/pusher/auth',
headers: {
'Accept': 'application/json',
'Authorization': 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwOlwvXC90ZXN0cy50ZXN0XC9hcGlcL3B1c2hlclwvYXV0aCIsImlhdCI6MTUzOTE2ODAwMSwiZXhwIjoxNTM5MTcxNjAxLCJuYmYiOjE1MzkxNjgwMDEsImp0aSI6IktMOHdsMG9Gb2FNZzA3UHkiLCJzdWIiOjEsInBydiI6Ijg3ZTBhZjFlZjlmZDE1ODEyZmRlYzk3MTUzYTE0ZTBiMDQ3NTQ2YWEifQ.nuSaYl3mvmTx-5YRQEviMqpry6gt-tWZig1gho-jlC4',
},
params: {}
},
})###公共频道示例
Echo.channel('order').listen('new', (e) => {
console.log(e);
}).listen('send', (e) => {
console.log(e);
});###private频道示例
Echo.private('order.1').listen('new', (e) => {
console.log(e);
}).listen('send', (e) => {
console.log(e);
});###presence频道示例
window.Echo.join(`chat.1`)
.here((users) => {
console.log('全部人员');
console.log(users)
})
.joining((user) => {
console.log('新人加入');
console.log(user);
})
.leaving((user) => {
console.log('有人退出');
console.log(user);
}).listen('NewMessage', (e) => {
console.log(e);
});###客户端事件 广播一个事件给其它已经连接的客户端
whisper 方法来广播客户端事件
Echo.private('chat')
.whisper('typing', {
name: this.user.name
});你可以使用 listenForWhisper 方法来监听客户端事件:
Echo.private('chat')
.listenForWhisper('typing', (e) => {
console.log(e.name);
});###订阅方法
Echo.subscribe('order');
Echo.subscribe('private-order');
Echo.subscribe('presence-order');###示意图

###socket服务配置 https://github.com/woguolufei/echo/blob/master/doc/socket.md
