使用套接字io为两条指令发送和获取数据
使用套接字IO进行数据的发送和获取是一种常见的网络通信方式。套接字（Socket）是一种网络通信的接口，通过套接字IO可以实现不同计算机之间的数据传输。
套接字IO的基本流程如下：
- 创建套接字：使用编程语言提供的套接字库函数，如Python中的socket模块，创建一个套接字对象。
- 绑定地址和端口：将套接字绑定到本地的IP地址和端口号，以便其他计算机可以通过该地址和端口与该套接字进行通信。
- 监听连接请求（可选）：如果需要作为服务器接受连接请求，可以调用套接字的listen函数开始监听连接请求。
- 接受连接请求（可选）：如果有客户端请求连接，服务器可以调用套接字的accept函数接受连接请求，并返回一个新的套接字对象，用于与该客户端进行通信。
- 发送数据：使用套接字的send函数向对方发送数据。可以将数据封装成特定的格式，如JSON、XML等，以便接收方能正确解析。
- 接收数据：使用套接字的recv函数接收对方发送的数据。可以根据通信协议和数据格式进行解析和处理。
- 关闭套接字：通信结束后，调用套接字的close函数关闭套接字。
套接字IO的优势在于：
- 灵活性：套接字IO可以在不同的计算机之间进行数据传输，可以实现不同平台、不同编程语言之间的通信。
- 实时性：套接字IO可以实现实时的数据传输，适用于需要及时响应的应用场景。
- 可靠性：套接字IO可以通过协议的校验和重传机制来保证数据的可靠传输。
套接字IO的应用场景包括但不限于：
- 网络通信：套接字IO是实现网络通信的基础，可以用于实现客户端和服务器之间的数据传输。
- 实时音视频传输：套接字IO可以用于实现实时音视频传输，如视频会议、直播等应用。
- 分布式计算：套接字IO可以用于不同计算节点之间的数据传输，实现分布式计算任务的协同处理。
- 物联网：套接字IO可以用于物联网设备之间的数据交互，实现设备之间的通信和控制。
腾讯云提供了一系列与套接字IO相关的产品和服务，例如：
- 云服务器（CVM）：提供了虚拟机实例，可以在云上搭建自己的套接字应用程序。
- 云数据库MySQL版（CDB）：提供了高可用、可扩展的MySQL数据库服务，可以用于存储套接字应用程序的数据。
- 云网络（VPC）：提供了灵活的网络配置和管理，可以用于构建套接字应用程序所需的网络环境。
- 云安全中心（SSC）：提供了网络安全防护和威胁检测服务，可以保护套接字应用程序的安全。
更多关于腾讯云产品和服务的信息，可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
我需要socket.io的帮助。我希望客户端发送信息，即服务器然后服务器将其发送回同一个客户端，而不是所有这些客户端。下面是如何设置代码: Client
var socket = io.connect();
socket.on("receive", function(data){
console.log(data);
});
socket.emit("send", "hello");
服务器
socket.on("send", function(data){
io.sockets.emit("recei
浏览 3提问于2016-10-29得票数 0
回答已采纳
1回答
从我之前的问题中，我了解到当一端发送FIN时，内核将停止阻止读取(因为FIN之后内核不再“期望”更多的数据，从而停止阻塞)。但这个问题是专门针对套接字的。因为read()和write()可以用于任何文件描述符(任何设备类型，例如，我可以从管道、套接字、char设备等读取)。根据所有这些设备类型，内核会执行某种阻塞操作。例如，通过管道，内核阻塞read()，直到管道的写入端被close()编辑(直到它“不希望”有更多的数据进入)。但问题是，如果内核按设备类型进行“某种阻塞”，并自行决定何时“期望”某些数据，何时不“期望”某些数据，
甚至“阻塞”部分是如何实现的？也就是说，进程如何在某一时刻停止其
浏览 4提问于2021-01-02得票数 2
回答已采纳
我正在为IO设备编写套接字客户端，这是tcp服务器。我能够共同连接和监听服务器定期发送的数据。但有时，我需要发送一些指令到服务器并读取它的响应。
什么是正确的方法来处理这个任务，能够侦听传入的数据和指令发送后，接收响应，并知道，接收到的数据中的一部分是响应？
如果设备正在发送数据，而我需要向设备发送数据，怎么办？我怎样才能调度这样的交通呢？我需要一个线程来读，一个用来写吗？是否可以使用每个设备的单个线程来处理这个问题(将有多达数百个设备连接)？
我正在使用Socket.Receive和Socket.Send方法。
浏览 4提问于2014-07-13得票数 0
回答已采纳
我正在使用回环API。server.js (服务器-> server.js)如下所示：
var loopback = require('loopback');
var boot = require('loopback-boot');
var app = module.exports = loopback();
app.start = function () {
return app.listen(function () {
app.emit('started');
console.log('Web server
浏览 3提问于2017-06-30得票数 1
回答已采纳
1回答
我在一种快速路由中使用socket.io来填充来自服务器的数据，并以不同的事件名、第一个套接字和第二个套接字将其发送到客户端。
var io
router.get('/start', function(req, res, next) {
io = req.app.get('socketio');
var socketlist = [{name:"firstsocket"},{name:"secondsocket"}]
for (var key in socketlist){
myInter
浏览 0提问于2019-07-30得票数 0
回答已采纳
2回答
嘿，伙计们，我需要帮助使用socket.io将数据发送给特定房间的特定用户，使用redis存储创建组管理员的id，但是如何从redis中获取用户id并在他们的房间中发送给他们
我的代码
const users = {}
const admins = {}
io.on('connection',socket =>{
socket.on('create-class',(address,userID)=>{
client.hmset(`${userID}`, `id`, `${userID}`);
})
socket.on('jo
浏览 1提问于2020-09-02得票数 0
c# winform尝试通过套接字发送node.js套接字。客户端连接到服务器，但socket.emit值和socket.on值不能正常通信。我想找个解决办法。
我希望将这个客户端名称作为json类型数据发送到服务器，从服务器接收json类型数据，读取它，并将数据发送回json。
socket.emit和socket.on的数据不能正常工作，所以代码被删除了。
c#代码
private void socketLogin(string email, string pw)
{
var socket = IO.Socket("http://localhost:3000/login.h
浏览 1提问于2020-02-27得票数 0
我想混合使用SSL和SOCKS套接字。换句话说，我希望通过SOCKS代理发送TLS加密数据，并且希望使用IO::Socket::SSL和IO::Socket::Socks 我能想到的唯一选择是将IO::Socket::SSL复制到从IO::Socket::Socks继承的IO::Socket::SocksSSL类中。这是获得正确订单(如发送)的唯一方法。我首先需要调用SSL方法，然后它将调用父(IO::Socket::Socks)发送。与connect相同，其中SSL连接将调用Socks连接，然后启动TLS协商。 不幸的是，IO::Socket::SSL没有允许子类轻松决定其继承内容的$SO
浏览 39提问于2019-05-03得票数 1
回答已采纳
2回答
检查插座闭合情况
、、
我有一个连接到某个服务器的应用程序。它可以同步发送数据(发送和等待应答)和异步接收数据。我做了两条线。在无限循环的第一个线程中，我发送数据并等待应答。在第二个线程中，我从服务器获取数据并将其推送到队列中。但是，如果在发送数据时(在第一个线程中)出现错误，我必须关闭套接字。我怎样才能检入套接字关闭的第二个线程呢？
第二个线程中的代码：
while (processing) {
nbytes = recv(socketDesc, canFrame, sizeof(data), 0);
if (nbytes > 0) {
push_queue(data);
}
if (
浏览 0提问于2016-02-14得票数 0
1回答
我在服务器JS文件中有Express代码：
app.post('/confirm', function (req, res) {
// Here I need to send socket with emit()
});
下面提到的代码我有Socket.io：
io.on('connection', function (client) {
// All methods
});
问题是我不能访问快速方法app.post()中的socket，也不能通过POST操作发送数据。
我该如何使用它呢？
浏览 0提问于2016-10-02得票数 0
我有一个windows应用程序(构建在C#上作为windows服务)，它将数据发送到NodeJs网络套接字，因此由于Socket.IO帮助使一个成为一个活动的应用程序，而不需要重新加载。我如何允许Socket.IO将从NodeJs网络套接字接收到的数据流到，在网络套接字从C#接收数据的确切时刻？
因此，在从C#接收套接字数据的代码中：
var net = require('net');
net.createServer(function (socket) {
socket.on('data', function (data) {
浏览 3提问于2018-01-15得票数 0
回答已采纳
1回答
我想知道如何在我的快递应用中正确地使用socket.io。
我有一个用express/node.js编写的REST，我想使用socket.io为我的应用程序添加实时特性。考虑一下，我想通过向REST发送一个请求来做一些我可以做的事情。我该怎么处理socket.io？我是向REST发送请求并向socket.io客户端发送进程的结果，还是在socket.io发射器中处理整个进程，然后将结果发送给socket.io客户端？
提前谢谢。
浏览 2提问于2021-04-28得票数 1
回答已采纳
4回答
新来这里的人。我正在阅读计算机网络(第三版)的书，在3.2节中，他们正在讨论UDP和TCP的多路复用/解复用。
在UDP协议中，套接字由源IP和源端口唯一标识。
在TCP协议中，套接字由源IP、源端口、目标IP和目标端口唯一标识。为什么TCP协议需要两条额外的信息才能使接收主机正确地解复用段并将其发送到正确的进程？
我认为这是必要的唯一原因是如果客户端总是将TCP段发送到与连接请求段相同的端口。例如，我的浏览器总是将数据发送到服务器的端口80，即使服务器已经在另一个端口上专门为该会话建立了TCP套接字。在这种情况下，TCP必须使用源IP和源端口信息来解复用到正确的套接字。它不能仅仅依赖于源IP
浏览 0提问于2018-10-30得票数 8
回答已采纳
我有一个快速应用程序，它打开了与我的前端反应应用程序的套接字连接。
每当有人用json数据向我的服务器发送post请求时，我想向连接的套接字发出一个事件，但是socket.emit在a.post回调中不会触发。然而，io.sockets.emit工作得很好，但在这种情况下对我没有任何用处。
这是失败的：
io.on('connection', (socket) => {
app.post('/event', (req, res) => {
socket.emit('someevent', req.body);
浏览 3提问于2016-06-16得票数 2
回答已采纳
我正在使用node.js & express编写一个web应用程序，通过ZeroMQ & socket.io向每个用户提供实时的流。
其概念是:通过订阅ZeroMQ发布者，node.js应用程序将完整的aprs流发送给它。当用户访问网页(全屏地图)时，将建立一个socket.io会话，并将地图当前可见区域的边界发送回服务器。然后，服务器可以将完整提要的范围限定为仅将地图上的新地点发送给用户。
它大部分都工作得很好，但当一个以上的人加载站点时，它就会崩溃。当前查看的地图的范围变为全局，如果您缩放/平移一个地图，它将开始在两个浏览器上显示新位置上的点。
我需要每个socket.io
浏览 2提问于2012-04-09得票数 3
回答已采纳
我正在编写一个套接字程序，它由一组从进程组成，这些进程将位于计算机集群中的每台计算机上，而主进程则指示它们将本地文件移动到远程节点上的远程从节点上。这些从进程的主要任务是从本地硬盘读取文件，并将它们传输到其他机器上的其他从进程。我希望将侦听文件数据和将文件数据发送到单个进程的功能。
是否有可能在同一进程中同时具有发送位和接收位？
//I want this to send a connect() request to every other slave node
initialize_Connections();
//Have an accept() call for accepting t
浏览 1提问于2014-04-18得票数 2
2回答
我是socket.io新手，我试着把连接到我的节点服务器的每个客户端区分开来。
我只想向一个客户端发送数据，而不是向所有客户端广播相同的数据。所以，我必须找到每个客户的一个独特的部分。
如果我拿到了，我就得做一些事情
io.on('connection', function (socket) {
var origin = socket.request;
console.log("hey, so , new ws connection is > "+origin);
});
但我得到了[object, Object]。
这个对象的内容是什
浏览 3提问于2015-12-24得票数 0
我在node.js上使用socket-io的http服务器没有运行。我使用npm install socket-io和运行服务器。
这是服务器的代码。
var static = require('node-static');
var http = require('http');
// Create a node-static server instance
var file = new(static.Server)();
// We use the http moduleÕs createServer function and
// rely on
浏览 0提问于2016-08-31得票数 0
你能帮帮我吗？我有一个与gen_tcp发送函数相关的问题。我一直在尝试从我的erlang服务器向flash客户端发送几个元组，大约10-15个项目，它们被解码为amf对象。
case get_tcp:send(Socket, Msg) of
ok -> io:format("sent~n");
{erorr, Err} -> io:format("~w~n", [Err])
end
没有错误，但flash客户端没有接收到大约8-11个项目的全部数据。套接字选项为binary、{active，true}、{reuseaddr，true}。我已经检查了我
浏览 13提问于2012-03-17得票数 1
我试图弄清楚，如果客户再次加入同一个房间会发生什么，为了测试并找到答案，我最初想知道在相同的客户发送更多的用户之后，有多少客户房间加入了这个房间，但是wiki 中的房间一章已经过时了。当我尝试使用"io.sockets.clients('room')“”I get error“时，Object#没有方法'clients'”。
因此，我有两个问题: 1.如果客户再次尝试加入同一个房间，会发生什么情况？他每一次尝试加入，都会得到那个房间的排泄物吗? 2.我怎样才能知道哪些客户在房间里？
Im使用socket.io v1.0.2
浏览 0提问于2014-05-29得票数 11
回答已采纳
在我的节点web服务器上，我遇到了一个很难调试的错误。
背景--我正在创建一个带有socket.io的节点服务器，以提供restful服务，连接到mongodb，它使用web套接字(socket.io)来处理服务器-客户端消息。
在我的节点应用程序中发布，我使用了一个名为节点调度器的npm包，在这个包中，我在设定的时间做了一些处理(这是非常动态的时间，但到目前为止运行得相当好)。
因此，我将启动一个作业，使用节点调度程序，当它结束时，您可以提供一个函数。
在这个函数中，我发出一条web套接字消息，这正是我在应用程序的其余部分中发出消息的方式，但是我的客户端从未接收到消息。
检查客户端断开连接的
浏览 2提问于2014-11-11得票数 0
3回答
今天，我想到了下面的设置。创建一个nodejs服务器以及express和socket.io。使用express，我将创建一个连接到mongo的RESTful API。BackboneJS或类似的应用程序将客户端连接到该REST。
现在，每当mongodb(即它感兴趣的数据中的数据)发生变化时，socket.io都会向客户端触发一个事件，而客户端将对已更改的数据进行跟踪。然后，客户端将触发适当的AJAX请求，以获得需要的新数据。
因此，socket.io连接的行为就像一个同步触发器。它将在那里进行整个访问，也可以以这种方式管理会议。所有的有效载荷都会通过http发送。
优点：
REST用于w
浏览 0提问于2012-07-17得票数 9
回答已采纳
1回答
我正在使用UDP创建一个服务器/客户端范例，但是Rust服务器没有接收到C++客户端消息。我已经能够成功地进行Rust服务器/ Rust客户端和C++服务器/ Rust客户端的通信。 这让我相信我的C++代码有问题，或者在向Rust发送C++ buffers时存在某种类型的通信错误，但我使用的代码我认为是有效的。这只是从同一台计算机发送和发送到同一台计算机，并未扩展到计算机到计算机。 我不是UDP / TCP方面的专家，所以我可能做错了什么 Rust服务器： use std::net::UdpSocket;
fn main() {
let udp: UdpSocket = UdpS
浏览 17提问于2019-04-16得票数 1
回答已采纳
1回答
我正在开发一个使用Node.js，Socket，io，Redis的实时应用程序。我试图从员工那里向一个客户端发送一条私有消息，但它不起作用。worker上的数组io.sockets.connected是空的，我不能引用客户机。
主机代码：
var io = require('socket.io')(30042); //socket.io(<port>) will create a http server
var redis = require('socket.io-redis');
io.adapter(redis({ host: 'loca
浏览 0提问于2017-02-16得票数 3
1回答
我正在构建一个客户端Ruby库，它连接到服务器并等待数据，但也允许用户通过调用方法发送数据。
我使用的机制是有一个初始化套接字对的类，如下所示：
def initialize
@pipe_r, @pipe_w = Socket.pair(:UNIX, :STREAM, 0)
end
我允许开发人员调用将数据发送到服务器的方法如下所示：
def send(data)
@pipe_w.write(data)
@pipe_w.flush
end
然后在单独的线程中有一个循环，从连接到服务器的socket和@pipe_r中进行选择。
def socket_loop
Thread.new
浏览 3提问于2016-04-22得票数 7
回答已采纳
我使用socket.io向一个角度控制器发送一个事件，该控制器为一个模态模板设置文本内容。
如果我还想在触发事件时调用modal()方法，我应该在控制器中执行此操作，还是在指令中执行此操作？
如果是后者，我是应该直接在指令中侦听socket.io事件，还是应该从控制器广播一个单独的事件？
浏览 2提问于2013-04-12得票数 2
回答已采纳
下面的代码确实适用于gen_tcp:connect()函数调用中的{packet,0}选项，但不适用于1、2和4(尽管我只针对4进行了测试，我假设1和2也不起作用)。我的问题是，为什么不呢?使用一个比另一个重要吗？基本上，Erlang文档没有对有关数据包选项的主题进行详细解释，Joe Armstrong的编程Erlang也没有给出任何详细信息；他只是解释说数据包不是按顺序重组的，尽管我一直认为tcp数据包是在发送时接收的，这与UDP不同。我有一个有趣的注意，上的客户机-服务器有{packet,4}作为选项，它工作得很好，与下面的代码非常相似。下面是以下代码中使用的{packet,4}选项的服务
浏览 3提问于2013-03-26得票数 1
回答已采纳
我正在开发一款大型的多人棋盘游戏。我的解决方案是服务器上的node.js socket.io。我需要解决方案来实现某种类型的objective-c套接字，它将与socket.io通信，以字符串形式发送和接收json对象。我不会将webkit与websocket一起使用。有没有可能？服务器将保存游戏状态，iphone客户端将向服务器发送动作并接收服务器返回的更改。
浏览 2提问于2011-02-10得票数 9
我编写了socket.io和nodejs代码，从数据库中获取值并将值发送给客户端，而无需使用setInterval进行刷新。它工作得很好，但我不想使用setInterval函数。因为有时我的数据库会在几小时内改变，有时以分钟为单位，有时以毫秒为单位。所以我不想使用setInterval函数。我只希望在数据库值更改时自动更新。就这样。我被困在里面了。
var express = require('express');
var app = express();
var server = require('
浏览 0提问于2019-06-21得票数 0
回答已采纳
我正在p2p上做一个大学作业。我需要完成的是创建和加入多播组，并使用UDP从peer1发送文件名请求到其他对等点，并在其他对等点中查找文件，并使用TCP将文件从对等(例如peer2)发送/接收到peer1，并使每个对等客户机/服务器使用下面的代码，但它显示已在使用的地址和IO异常，请帮助我。
主要方法Peer
import java.net.*;
import java.io.*;
public class Peer {
public static void main (String args[])
{
// we need to give follo
浏览 1提问于2017-09-20得票数 0
2回答
我在为tcp-ip服务器客户端编写代码.我面临的问题是:我的服务器使用Java并监听一个端口，如果它找到了什么，它就会打印它找到的东西。
我在Java中有一个客户机，在C中有一个客户机。当我使用我的Java客户端并发送字符串"hello server“时，服务器发现并打印出来，但是当C客户机使用winsock.h的”发送“发送它时，Java服务器在行上出现错误:：(我使用Buffereader和readline从Java服务器的tcp-ip端口获取数据)
commandFromPortal = inFromClient.readLine();
这些错误是：
浏览 1提问于2012-01-19得票数 0
我在expressJS中使用socket.io
我在bin/www中有套接字连接
我想让我在向sendmessage.js发送数据时，使用sendmessage.js中的socket.emit()向客户端发送数据
bin/www
var io = require('socket.io')(server, {
pingInterval: 10000,
pingTimeout: 5000,
}).listen(server)
io.on('connection', function(socket){
socket.on('messageData&
浏览 2提问于2018-10-22得票数 0
2回答
WSAEWOULDBLOCK处理
、、、、
我已经为使用winsock的C++服务器编写了一个套接字。套接字使用异步方法发送、接收和接受连接。在生产环境中实现套接字后，send函数停止工作，出现错误WSAEWOULDBLOCK。根据我在网络上的研究，这意味着套接字IO的网络缓冲区已满，或者网络太忙，此时无法执行我的操作。然而，我看不到有任何具体的解决方案可以解决这个问题。我的临时解决方案是围绕WSASend函数创建一个do-while循环，让线程休眠X个MS，然后重试。这导致了比以前的套接字(.NET套接字类)更高的延迟和更大的延迟尖峰。
我发送数据的代码如下：
void Connectivity::ConnectionInformat
浏览 1提问于2012-12-23得票数 4
回答已采纳
下面是我的连接函数，我将套接字添加到SOCKET_LIST全局函数中，以便稍后可以遍历它。
Player.onConnect执行初始化，如果没有打开的房间，则会创建一个新的房间；如果有人正在等待oponent，则会加入一个房间。
io.sockets.on('connection', function(socket) {
SOCKET_LIST[socket.id] = socket;
Player.onConnect(socket);
});
然后，我尝试将所有数据发送给同一房间中的用户。但它并不只是将数据发送给房间里的人，而是最终将数据发送给连接到服
浏览 2提问于2016-03-28得票数 0
我使用Node和socket.io来实现基本的聊天应用程序。每个编写任何消息的客户端都会广播到连接到服务器的所有客户端(它是一个跨浏览器的应用程序)。现在我希望只有一个客户端可以首先访问服务器，可以转发消息给所有人，而其他订阅用户只能接收消息(不能向任何人发送数据)。我的问题是，当服务器上的客户端向所有客户端发出发送数据的请求时，我应该如何识别它？
这是服务器端实现：
var app = require('express')()
, server = require('http').createServer(app)
, io = require
浏览 0提问于2013-06-11得票数 0
回答已采纳
我正在使用为Android实现一个简单的防火墙。我的应用程序类似于，但它不会将原始IP数据包发送到远程VPN服务器，后者会将它们转发到目的地。
我的实现在这里：
我能在本地做所有这些转发例程吗？这就是我想要实现的。
我初始化了TUN设备及其文件描述符：
mInterface = new Builder().setSession(getString(R.string.app_name))
.addAddress("10.0.2.1", 24)
.addRoute("0.0.0.0", 1)
浏览 1提问于2015-05-05得票数 24
回答已采纳
我可以在服务器上发送带有字符串标记的数据
import io = require('socket.io');
var sio = io.listen(server);
sio.sockets.on('connection', function (socket) {
socket.emit('news', { hello: 'world' });
socket.on('my other event', function (data) {
console.log(dat
浏览 1提问于2014-09-28得票数 2
回答已采纳
io.sockets.emit和socket.broadcast.emit有什么不同？是否只向发送它的套接字以外的所有人发送广播？
它们似乎可以互换使用：
io.sockets.on('connection', function (socket) {
//these should do the same thing
io.sockets.emit('this', { receivers: 'everyone'});
socket.broadcast.emit('this', { receivers: 'e
浏览 1提问于2012-04-27得票数 111
回答已采纳
据我所知，允许在没有任何特定传输层协议的情况下发送和接收IP数据包。
dart的"dart:io“附带了类，该类定义为套接字的低级接口(可能指的是TCP套接字)。
我的问题是Dart的RawSocket是否允许直接发送和接收IP数据包？如果没有，有没有办法在Dart中做到这一点？
浏览 5提问于2017-06-19得票数 4
我正在使用JProfiler评估许可证来分析一个将数据写入套接字的客户端应用程序。在启动客户端并单击Record Probe Sockets后，我成功地连接到客户端。Time Line选项卡显示应用程序启动和终止时的两条垂直红线。但是，Sockets选项卡没有显示任何内容。
我知道数据正在被写入套接字，因为我看到了服务器上的数据。客户端使用多个线程将数据写入套接字。
要使用JProfiler分析套接字的使用情况，我还需要做什么吗？我真正想看到的是，我的应用程序使用了多少时间来写入套接字，以及它在等待写入套接字时被阻塞了多少时间。
浏览 3提问于2016-07-27得票数 0
1回答
所以，我正在设置一个特快应用程序，里面有护照、猫鼬、连接闪存等所有常见的东西，我正在使用socket.io监听和发送消息。
目前，我只是发送信息给每个人(稍后将设置房间)和一切(但这)是伟大的工作。当终端用户访问任何页面时，所有当前连接的用户都会收到一条消息"Hi everyone!"，而刚刚连接的用户显然也会发送给他们自己的消息。到目前为止都是预料中的..。
问题：，我有一个页面，上面有一个按钮.
<button id="register" type="button" class="btn btn-warning">
浏览 1提问于2016-05-06得票数 1
回答已采纳
我通过Rabbitmq创建了一个队列系统，并通过套接字向用户发送通知。基本上有3个文件。
-index.js //some functions to save data and send to Rabbitmq
-socket.js //socket io modules
-consumer.js //some functions to consume data from Rabbitmq
当npm运行时，启动index.js和consumer.js。
index.js
const Express = require('ex
浏览 2提问于2022-01-10得票数 1
回答已采纳
我设置了一个测试平台，试图在同一个客户端和后端服务器之间创建两个套接字。在打开调试之后，我可以看到对两个不同的套接字(AAAA和AAAB)的xhr open GET请求，以及相应的套接字接收类型为"open“的消息，以及数据的sid回显套接字id (AAAA或AAAB)。我在下面的追踪中突出了这些。然而，这两种情况都发生在socket.on之前(“connect.函数被调用，因此socket.io.engine.id只反映第二个套接字的请求，而该方法似乎被调用了两次)。如果我猜的话，查找将看到用于两个连接的URI结尾，并且正在读取后者(好像它无法区分两个未执行的调用)。我正在维护一个执
浏览 4提问于2015-09-28得票数 0
回答已采纳
1回答
我将C#包装器用于ZeroMQ，但这似乎更像是ZeroMQ的一个潜在问题。
有什么方法可以在不阻塞和的情况下推送消息而不排队呢？如果服务器没有启动，我希望这些消息能够永久地被释放，而不会阻塞。
以下是我迄今尝试过的设置：
1)
发送(阻塞发送)
高水标=0
这(很明显)不阻塞，但是它似乎在内存中排队，直到套接字连接(进程的内存不断上升)。
2)
发送(非阻塞发送)
高水标=1
这是比赛条件。如果我迅速地连续发送两条信息，有时会有一条信息因为超过了高水位而被丢弃。
3)
轮询套接字以确定它是否会阻塞。这并没有真正的帮助，因为在队列开始阻塞之前，我仍然必须将一条(旧的)消息放入队列中(如果我设置了
浏览 1提问于2012-12-11得票数 3
我目前正在开始使用node.js，作为第一个小项目，我决定编写一个小聊天应用程序。到目前为止，我正在使用socket.io，并且已经学习了上的聊天教程。现在我想在脚本上展开，但是我被卡住了。
我无法理解socket.io是如何管理服务器端所有连接的客户端的(或者根本不理解)。我可以使用io.emit函数向所有连接的用户发送消息。但是，如果我想要向某个特定用户发送消息，该怎么办？
当然，我可以通过将消息发送到所有客户端，然后在客户端检查标识符等方式来“伪造”它，并且只在匹配的情况下才处理消息。但这仍然会将消息发送给每个人，并且它可以很容易地被具有最少JS知识的用户所规避。
出于安全原因，“过滤”
浏览 2提问于2015-08-10得票数 1
如何使用socket.io向单个套接字发送消息。
我在想这样的事情，但不起作用。
io.sockets.socket(socket.id).emit('messagetype', "message")
我知道这个错误：
TypeError: Property 'connected' of object #<Namespace> is not a function
我想我只是在语法上出了点问题，但找不到它的来源。
浏览 1提问于2014-12-26得票数 0
回答已采纳
Socket.io文档似乎指定了向房间中所有连接的客户端发送事件的几种方法。它们如下：
io.to()，如第一个示例所示：
io.in()，正如在emit中所发现的，在这里可以找到：
socket.to()，如下所示：
除了上面链接的示例之外，文档中没有列出io.to()和io.in()。这些方法到底是做什么的，我在哪里可以找到更多关于它们的信息？
socket.to()可以在io.on('connection', callback)事件中使用，如下所示：
io.on('connection', function(socket){
//
浏览 2提问于2017-03-23得票数 8
回答已采纳
我正在使用socket.io创建一个投票功能。插座由channelId放置在房间里。每当房间中的任何套接字发出vote事件时，我都试图将当前的vote-list发送到该房间中的所有套接字。
我的问题是，如果我在同一个房间中有套接字A、B、C，则B和C可以看到来自套接字A的选票(即调用B和C的on.('vote')侦听器)，而不是A本身。
我希望发生的是，如果套接字A、B、C位于同一个房间，而A发出一个vote，那么所有的套接字A、B、C vote侦听器都会被调用。
客户端：
这些侦听器是在方法中定义的，但为了清晰起见，我已经将它们单独挑出来了。定义了所有变量。
const so
浏览 3提问于2017-09-14得票数 2
回答已采纳
1回答
如何实现无限循环
、、、、
实现IRC客户端(仍然)。我几乎什么都有，但今天我注意到，有一个主要问题。
我得到了服务器发送给我的所有数据，但是如果我除了显示它发送给我的数据之外什么也不做，我的while(1)循环只检查一次是否还有数据要接收，然后停止。仅当我键入并发送某些内容时才重新启动，然后在发送我键入的内容之后，它会检查套接字上是否有任何数据在等待，并最终显示它。
这显然是错误的，因为在这种情况下，只有当我发送一些东西时，我才会看到以前激化的消息。
这是我的代码：
while(1){
if((readReady = readReadiness(sockfd))==0){ //nothing to r
浏览 3提问于2012-05-18得票数 0
有没有办法使用socket.io在两个不同的网页之间共享数据？假设我有page1.html和page2.html，它们是从同一网络中的不同设备访问的，我从page1向page2发送一个字符串。根据我所看到的，我可以使用node.js和socket.io，基于socket.io的聊天示例来制作它。但是我不知道怎么做。
有什么帮助吗？谢谢。
浏览 1提问于2016-09-19得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
