node.js - Socket.io 不断向每个客户端发出请求的数据
问题描述
这是代码:
客户
var server = "localhost";
var socket = io('http://' + serve + ':4005');
socket.on('connect',function(){
socket.emit('send', {type:"<?php echo $datatype?>"}); //{type:"3,2"}
});
这是我的节点 js 服务器的代码:
服务器
io.on('connection', function(client) {
console.log('Client connected...');
client.on('join', function(data) {
console.log(data);
});
client.on('send',function(data){
var datafinal = [];
setInterval(function () {
var usertype = data.type;
var types = usertype.split(',');
for (var i = 0; i < types.length; i++){
datafinal.push(apifinaldata.filter((inbound) => inbound.usertype == types[i] && inbound.active == 1 ));
}
var final = datafinal.reduce(function(a, b) {
return a.concat(b);
}, []);
datafinal = [];
io.emit('finaldata', final); io.emit('callwaiting', callsdatafinal);
}, 1000);
})
});
server.listen(4005);
当我启动服务器时,它会收到来自客户端 A 的请求,其中包含它想要的数据类型(例如{type : "3,2" }
。所以服务器只向客户端发出该特定数据。但是当另一个客户端说 B 要求服务器发送数据时{type : "1"}
,在在这种情况下,服务器分别向客户端 A 和 B 发出正确的数据,但客户端没有连续接收数据。服务器不断发出,但有时它有时向 A 发出,有时向 B 发出。我希望服务器不断发出向每个连接的客户端请求数据。
另外,如果我更改 io.emit('finaldata', final); io.emit('callwaiting', calldatafinal); 到 client.emit('finaldata', final); client.emit('callwaiting', calldatafinal); 它不会向任何客户端发出任何数据。
所以我想要一个解决方案,使服务器只向每个客户端持续发送每个客户端请求的特定数据
我怎样才能做到这一点?
解决方案
为此,您必须跟踪客户端 A 和 B,然后仅将数据发送到特定客户端,以下是示例代码。
var clientA;
var clientB;
io.on('connection', function(client) {
console.log('Client connected...');
client.on('join', function(data) {
if (something){
clientA = client;
}
else {
clientB = client;
}
console.log(data);
});
client.on('send',function(data){
var datafinal = [];
setInterval(function () {
var usertype = data.type;
var types = usertype.split(',');
for (var i = 0; i < types.length; i++){
datafinal.push(apifinaldata.filter((inbound) => inbound.usertype == types[i] && inbound.active == 1 ));
}
var final = datafinal.reduce(function(a, b) {
return a.concat(b);
}, []);
datafinal = [];
if(someCondition){
clientA.emit('finaldata', final);
clientA.emit('callwaiting', callsdatafinal);
}
else {
clientB.emit('finaldata', final);
clientB.emit('callwaiting', callsdatafinal);
}
}, 1000);
})
});
这里clientA和clientB是连接的两个客户端,可以根据条件或者程序逻辑向任意客户端发送数据。
推荐阅读
- c# - 尝试查找类是否在帧之间发生更改的问题
- android - Android 数据绑定问题:无法反转表达式 XXX
- python - 如何开发代码以使用 pandas 自动按日期抓取数据
- vb.net - 多 IP ping
- java - Nagios 可以使用任何自定义 API 吗?
- android - RxJava - 在“订阅” lambda 中使用不同类型的变量(多链运算符的结果)
- git - 如何构建最适合 Git 的文件夹?
- visual-studio - Visual Studio 2017 升级后的 cl 不是完整路径,在 PATH 中找不到
- javascript - 如何制作机器人Whent,机器人
- ios - 使用 Realm 为新属性赋值时崩溃