3.1.25 • Published 3 years ago
socket.io-amqplib v3.1.25
socket.io-amqplib
使用 amqplib 作为 SocketIO 的消息中间件,该对象是根据 socket.io-redis@4.0.1 改的, 支持原先的 API ,不过删除了 remoteJoin and remoteLeave
使用方式
var io = require('socket.io')(3000);
var amqplib = require('socket.io-amqplib');
io.adapter(amqplib("amqp://user:123123@127.0.0.1", { key: "socketio", host: 'localhost', port: 6379 }));
AmqplibAdapter#clients(rooms:Array)
返回所有节点上连接到“房间”的客户端ID列表. See Namespace#clients()
io.of('/').adapter.clients().then(function (clients) {
console.log(clients); // an array containing all connected socket ids
});
io.of('/').adapter.clients(['room1', 'room2']).then(function (clients) {
console.log(clients); // an array containing socket ids in 'room1' and/or 'room2'
});
// you can also use
io.in('room3').clients().then(function (clients) {
console.log(clients); // an array containing socket ids in 'room3'
});
AmqplibAdapter#clientRooms(id:String)
返回具有给定ID的客户端已加入的房间列表(即使在另一个节点上)。
io.of('/').adapter.clientRooms('<my-id>').then(function (rooms) {
if (err) { /* unknown id */ }
console.log(rooms); // an array containing every room a given id has joined.
});
AmqplibAdapter#allRooms()
返回所有房间的列表。
io.of('/').adapter.allRooms().then(function (rooms) {
console.log(rooms); // an array containing all rooms (accross every node)
});
AmqplibAdapter#join(room:String)
使具有给定id的套接字加入房间。
socket.join(roomid).then(function(){
console.log("success")
});
AmqplibAdapter#leave(room:String)
使具有给定id的套接字离开房间。
socket.leave(roomid).then(function(){
console.log("success")
});
AmqplibAdapter#remoteDisconnect(id:String, close:Boolean)
使具有给定id的套接字断开连接。 如果close
设置为true,它也会关闭底层的套接字。
io.of('/').adapter.remoteDisconnect('<my-id>', true).then(function () {
console.log("success")
});
AmqplibAdapter#customRequest(data:Object, fn:Function)
向每个节点发送一个请求,该请求将通过customHook
方法进行响应。
// on every node
io.of('/').adapter.customHook = function (data, cb) {
cb('hello ' + data);
}
// then
io.of('/').adapter.customRequest('john').then(function(replies){
console.log(replies); // an array ['hello john', ...] with one element per node
});
License
MIT
3.1.23
3 years ago
3.1.22
3 years ago
3.1.25
3 years ago
3.1.24
3 years ago
3.1.21
3 years ago
3.1.12
3 years ago
3.1.11
3 years ago
3.1.14
3 years ago
3.1.13
3 years ago
3.1.16
3 years ago
3.1.15
3 years ago
3.1.18
3 years ago
3.1.17
3 years ago
3.1.10
3 years ago
3.1.20
3 years ago
3.1.19
3 years ago
3.1.7
3 years ago
3.1.9
3 years ago
3.1.8
3 years ago
3.1.3
3 years ago
3.1.6
3 years ago
3.1.5
3 years ago
3.1.4
3 years ago
3.1.2
3 years ago
3.1.1
3 years ago
3.0.1
3 years ago
3.0.0
3 years ago
2.1.2
3 years ago
2.1.1
3 years ago
2.1.4
3 years ago
2.1.3
3 years ago
2.0.1
3 years ago
2.0.0
3 years ago
1.0.0
3 years ago