1回答
我正在尝试将socket.io封装在类中，以便在多个文件中共享相同的套接字(使用导入)。如果您只使用一个文件，这是使用WebSockets的常见方法。
Test.js
let ip = "http://localhost/";
let socket = io(ip);
socket.emit("message", {"content": "hello"});
socket.on("messageResponse", function(content) {
//Do something here.
});
我
浏览 1提问于2019-12-18得票数 1
回答已采纳
2回答
正确关闭JeroMQ
、、、
我想知道如何正确地关闭JeroMQ，到目前为止，我知道三种方法都有各自的优缺点，我不知道哪一种是最好的。
情况：
线程A:拥有上下文，应该提供开始/停止方法
线程B:实际侦听器线程
我现在的方法是：
螺纹A
static ZContext CONTEXT = new ZContext();
Thread thread;
public void start() {
thread = new Thread(new B()).start();
}
public void stop() {
thread.stopping = true;
thread.jo
浏览 4提问于2014-03-27得票数 8
回答已采纳
我试图在多处理中读写字节数组.是否有办法使该方法适用于子进程？
由于定义mp和套接字的代码太多，我将尽可能地总结
我尝试过在每个进程中导入config.py。
config.py:
x = 0 # Default value of the 'x' configuration setting
y = 0
mod.py:
import config
def run_socket(socket):
data = socket.recv(8)
config.x = int.from_bytes(data[0:4])
config.y = int.fro
浏览 2提问于2019-10-02得票数 0
回答已采纳
1回答
PHP中最快的IPC
、、、、
我想知道，在PHP中从一个进程向另一个进程发送数据最快的方法是什么？数据只是一个短字符串。最近，我开发了一个使用AF_UNIX套接字的解决方案，但基准测试显示，将数据从一个进程传递到另一个进程需要0.100毫秒。我想知道，共享内存是否可以更快？但是，我不知道，如何让其他进程定期检查共享内存来检测，是否有新的数据写入？
当前解决方案：
$server = socket_create(AF_UNIX, SOCK_STREAM, 0);
socket_bind($server, '/tmp/mysock');
socket_listen($server);
while(true) {
浏览 2提问于2010-11-24得票数 6
在REST调用和一些数据库插入之后，我希望通过socket.io向前端发出一个新的通知，如下所示：
socket.broadcast.emit('send notification', notification);
由于我使用的函数是通过REST触发的，而不是通过socket.io触发的，所以我没有变量“套接字”。
一开始我想我可以像这样说：
var io = require('socket.io') // or like: require('socket.io')(3000)
在这里，我想我可以得到这样的名称空间：
var nsp = io.o
浏览 0提问于2015-04-23得票数 3
回答已采纳
2回答
我是新手，寻找解决方案，如何通过参考在文件(模块)之间共享一个变量。举个例子，我的这里是app.js
const users = {},
waitingQueue = []
module.exports = function(io){
io.on('connection', (socket)=>{
users[socket.id] = socket
socket.on("Search", (d, ack)=>{
waitingQueue.push(socket)
浏览 7提问于2017-08-21得票数 0
目前，我有一个getter/setter套接字模块，如下所示
var socket;
module.exports.getSocket = getSocket;
module.exports.setSocket = setSocket;
function getSocket() {
return socket;
}
function setSocket(sock) {
if (undefined == socket) socket = sock;
}
在app.js中，我的设置如下
var sio = require('./lib/socket');
var
浏览 0提问于2012-04-24得票数 4
回答已采纳
我有这个服务器和客户端应用程序，它计算一个按钮被点击了多少次。在座的其他一些议员也很好地解决了我以前提出的问题，现在我又有了另一个问题。
当我启动服务器，客户端连接，客户端单击按钮时，服务器端的计数器就会上升。但是，当第二个客户端连接到服务器时，计数器将重置为0。我认为服务器出于某种原因创建了计数器的独立实例。
以下是(更新的)服务器端代码：
public class Server {
public static void main(String[] args) throws Exception {
Socket socket = null; //create a new sock
浏览 1提问于2015-11-11得票数 0
回答已采纳
1回答
无法在线程之间共享套接字
、、、
我正在构建一个多线程的perl TCP服务器，它使用不同的线程来处理不同的客户机。为此，我维护了一个线程池，它跟踪线程是空闲的还是正在工作的。
在主线程中，我打开一个侦听套接字，并使用以下命令绑定到特定端口：
$socket = new IO::Socket::INET(Localhost => '127.0.0.1',
LocalPort => '5000',
Proto => 'tcp',
Listen => $MAX_THREADS, Reuse => 1) or die &
浏览 1提问于2013-12-28得票数 2
2回答
我正在学习一本书，书中有一个用于socket.io名称空间的代码片段。书中指定的版本是socket 0.9。
下面是使用名称空间的简单聊天室的代码。
exports.initialize = function(server) {
io = io.listen(server);
var chatInfra = io.of("/chat_infra")
.on("connection", function(socket) {
socket.on("set_name", function(data) {
so
浏览 8提问于2016-01-06得票数 0
回答已采纳
有没有什么有效的例子可以存储会话，并将这些会话用于所有打开的窗口，让一个用户只连接到一个房间一次？
此应用程序将获得node.js会话形式的phpsession，但我找不出如何让一个人只访问此聊天应用程序一次
//define what we need
var express = require('express'),
app = express(),
memcache = require("memcache"),
http = require('http'),
server
浏览 1提问于2013-01-19得票数 0
1回答
我使用的是快速会话，我在登录页面上设置了会话对象。一切都很好。我的socket.io连接直到更深入的站点才被启动和使用。阅读socket.io文档时，它提到您可以访问启动套接字连接的request对象。这似乎与快速会话对象不一样，即：
io.on("connection", function (socket) {
console.log(socket.request.session)
});
输出undefined。有一个request对象，即：console.log(socket.request)输出[object Object]。
是否有一种方法可以通过socket
浏览 2提问于2017-09-15得票数 0
回答已采纳
我的FTP服务器是IIS。我在STOR文件之后关闭了数据套接字，但是我发现cmd套接字被阻塞了。这很奇怪。服务器数据套接字似乎还在等待数据。这是我的密码
int client_data_socket = enter_passvie_mode(client_cmd_socket, client_cmd_port + 1, send_buffer, recv_buffer);
FILE *fp;
if ((fp = fopen(filename, "rb")) == NULL)
{
close(client_data_socket);
printf("ope
浏览 0提问于2018-06-21得票数 0
回答已采纳
1回答
在Python库文件Python34/Lib/socket.py中，导入了_socket模块：
import _socket
from _socket import *
但是我在图书馆的任何地方都找不到_socket。
谁能解释一下什么是_socket？
浏览 0提问于2015-10-30得票数 5
我正在尝试用python触发器过程实现类似于复制的东西。
过程
CREATE OR REPLACE FUNCTION foo.send_payload()
RETURNS trigger AS
$$
import json, zmq
try:
payload = json.dumps(TD)
ctx = zmq.Context()
socket = ctx.socket(zmq.PUSH)
socket.connect("ipc:///tmp/feeds/0")
socket.send(payload)
socket.c
浏览 1提问于2013-02-06得票数 1
回答已采纳
3回答
我正在使用socket.io创建一个应用程序，我的问题是，当用户在同一浏览器中打开多个选项卡时，它将创建新的会话id socket.id。如何在所有选项卡中携带相同的会话id？
我看过一些帖子，就像这些帖子 it using express session一样，但这些帖子如何帮助我在浏览器的所有标签页中携带相同的socket.io会话id？
上面提到的帖子已经过时了，你能帮我解决这些问题吗？
谢谢。。
浏览 1提问于2012-10-07得票数 1
回答已采纳
我想用Python做一个多进程的UDP服务器，监听一个类中每个进程的一个端口：
processListener.py
import multiprocessing
import socket
class processListener(multiprocessing.Process):
def __init__(self):
multiprocessing.Process.__init__(self)
self.data = None
def run(self):
self.startServer()
return
def startServer(self
浏览 2提问于2013-05-12得票数 0
回答已采纳
我参考了本教程，并设法在本地主机上运行了简单的聊天应用程序。
我想了解一些事情：
我正考虑从彗星长轮询技术切换到这个websocket(php)，因为我脑子里只有一个问题，那就是不运行在APACHE中。我知道阿帕奇不是实时信息的正确选择。它为每个连接创建请求，因此占用了大量内存，极大地减缓了我的PC。
我希望上面的教程中的websocket不会以任何方式处理apache。它应该在自己的独立服务器上运行。
然而，我无法确定它是单独运行还是使用apache，因为我对、websocket、和实时技术非常陌生。
1)握手：
var wsUri = "ws://localhost
浏览 2提问于2016-09-19得票数 0
回答已采纳
1回答
我目前正在使用蓝牙设备，目标是将数据(只是一个文本字符串)从raspberryPi2发送到安卓智能手机。
让我补充一句，我知道所谓的“配对”过程和发现的存在。我已经能够成功地将数据从手机发送到我的计算机(Windows10)。但是，我不能在RaspberryPi和电话之间接收或发送数据。在Windows中:只能从手机接收数据，但不能将数据发送到手机。
我使用的代码(在计算机上接收)如下：
from bluetooth import *
server_socket=BluetoothSocket( RFCOMM )
server_socket.bind(("", 3))
serv
浏览 2提问于2018-08-15得票数 1
我正在尝试JUnit规则: ExternalResource，并且看不出@之前和@之后有什么不同。
@Rule
public ExternalResource externalResource = new ExternalResource() {
@Override
protected void before() throws Throwable {
super.before();
LOG.info("before");
serverSocket = new ServerSocket(2004, 10);
浏览 1提问于2012-09-03得票数 1
回答已采纳
socket.gethostbyname(socket.gethostname())在OS Capitan上运行良好。然而，在Mac更新到macOS Sierra之后，它现在不能工作了。
谢谢!
import socket
socket.gethostbyname(socket.gethostname())
Traceback (most recent call last):
File "<pyshell#26>", line 1, in <module>
socket.gethostbyname(socket.gethostname())
浏览 0提问于2016-10-11得票数 42
1回答
我不明白为什么会发生这种事，因为它以前运转得很好。
我使用以下库：
"express-socket.io-session": "^1.3.2"
"socket.io": "^2.0.3"
"express": "^4.15.4"
"express-session": "^1.15.5"
我通过http请求登录用户，并将cookie发送回前端。在http上的所有操作都与前端的cookie完美地工作，后端交换。
2-在用户登录后，我告诉前端"ok，user登录，现
浏览 4提问于2017-10-13得票数 3
我正在努力弄清楚如何水平地缩放我的nodejs TCP Server。
示例服务器：
var socketServer = net.createServer(function (socket) {
// Identify this client
socket.name = socket.remoteAddress + ":" + socket.remotePort
// Put this new client in the list
clients.push(socket);
sockets[s
浏览 4提问于2013-12-22得票数 3
1回答
我注意到python的socket.getaddrinfo()有一些奇怪的行为。
如果我连接到wifi并调用socket.getaddrinfo()，它就能工作(当然可以！)：
In [3]: socket.getaddrinfo('charlesleifer.com', 80)
Out[3]:
[...]
如果断开连接，则会收到一个错误：
In [4]: socket.getaddrinfo('charlesleifer.com', 80)
-------------------------------------------------------
浏览 2提问于2014-02-26得票数 0
我有一个boost套接字做async_read_some
socket_.async_read_some(boost::asio::buffer(data_, max_length),
boost::bind(&Session::handle_read, this,
boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
删除我的Session类时，调用socket_.close()。我以为这会取消async_read_some，并用错误调用Session
浏览 7提问于2013-09-10得票数 0
回答已采纳
1回答
Apache安装
、、、
我正在做一个项目，我正在使用Apache。我下载了Apache for C，并按照提供的说明在我的系统上安装它(UbuntuLinuxv14.04)。安装之后，我在/include目录下有一些头文件，在/lib目录下有一些库。所有这些都是从Apache安装的。
此时，我创建了我的C源文件，如下所示：
1) socket_client.h：
#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include "avro.h"
#include <errno
浏览 2提问于2014-06-19得票数 0
回答已采纳
1回答
增强asio多线程
、、、、
可能重复：
是
boost::asio::ip::tcp::socket
线安全吗？
我的意思是，我可以调用来自不同线程的共享tcp::socket (socket.connect()、read_some()、close())的方法，而不必担心竞争条件问题？
浏览 4提问于2013-01-19得票数 1
回答已采纳
1回答
我有一个python脚本，只有一个socket对象连接到java服务器。
我启动了一个线程，用于每5秒向服务器发送一次心跳消息。
和另一个线程，用于接收来自服务器的消息。
顺便说一句，所有的数据发送/接收都是协议缓冲区格式。
# socket_client.py
def recv_handler():
global client_socket
while True:
try:
# read 4 bytes first
pack_len = client_socket.recv(4)
pa
浏览 1提问于2016-12-07得票数 0
我有一个问题要建立集群node.js / socket.io应用程序，与socket.io商店，不是基于Redis，而是基于MongoDB。我需要指出的是，我的应用程序使用Mongo存储数据。因此，我不想设置另一个DB，仅仅是为了使soket.io跨多个进程工作。
我找到了一个选项-- ，但看起来我无法使它与节点集群一起工作。我使用的是节点: 0.10.10，以及socket.io: 0.9
我正在寻找允许我使用MongoDB作为运行在不同进程上的socket.io的存储库的任何解决方案。
就靠你了，谢谢。
浏览 1提问于2013-06-16得票数 1
回答已采纳
问:是否有可能对使用Socket.io进行WebSocket支持的应用程序进行集群？如果是这样的话，什么是最好的实现方法？
我已经构建了一个使用Express和Socket.io的应用程序，它构建在Node.js上。我希望结合集群来增加我的应用程序可以处理的请求数量。
以下原因导致我的应用程序产生套接字握手错误.
var cluster = require('cluster');
var numCPUs = require('os').cpus().length;
if (cluster.isMaster) {
// Fork workers.
for
浏览 2提问于2012-02-11得票数 2
回答已采纳
1回答
将boost套接字存储在向量中
、、、、
这是密码。我得到以下错误：
In member function ‘void socks4Server::listener(int)’:
sock4.cpp:16:49: error: no matching function for call to ‘std::vector<boost::shared_ptr<boost::asio::basic_stream_socket<boost::asio::ip::tcp>>>::push_back(boost::asio::ip::tcp::socket*)’ sockets.push_back(new tcp
浏览 4提问于2014-08-20得票数 2
回答已采纳
1回答
我的HP-242 G1笔记本正在运行Ubuntu14.04LTS。我的蓝牙没电了。见图：
📷
在终端中运行dmesg | grep -i blue的结果是：
[ 16.233056] Bluetooth: Core ver 2.17
[ 16.233078] Bluetooth: HCI device and connection manager initialized
[ 16.233086] Bluetooth: HCI socket layer initialized
[ 16.233089] Bluetooth: L2CAP socket layer initializ
浏览 0提问于2015-09-24得票数 0
1回答
当我单击startChat按钮时，websocket连接就建立了，当我单击hideChat时，websocket连接应该会断开。
const startChat = () => {
let webSocketConnection = "wss://ulw5fo03rf.execute-api.eu-west-1.amazonaws.com/dev"
var socket = new WebSocket(webSocketConnection)
setShowChat(true);
socket.onopen = function(even
浏览 1提问于2021-06-14得票数 0
我刚刚创建了一个web应用程序，它使用本地服务器中的套接字。一切都正常。当我将资源托管在1和1共享服务器上时，问题就开始了。我得到以下致命错误
致命错误:调用未定义函数socket_create ()
很明显，扩展php_socket没有启用。有一种方法可以通过代码启用这个扩展吗？
浏览 2提问于2013-10-21得票数 2
回答已采纳
#include <boost/thread.hpp>
#include <boost/bind.hpp>
#include <boost/asio.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
using namespace boost::asio;
typedef boost::shared_ptr<ip::tcp::socket> socket_ptr;
boost::asio::io_servi
浏览 15提问于2021-05-01得票数 0
在这个里，
#include <cstdlib>
#include <iostream>
#include <memory>
#include <utility>
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
class session
: public std::enable_shared_from_this<session>
{
public:
session(tcp::socket socket)
: socket_(std::move
浏览 3提问于2018-06-05得票数 2
回答已采纳
这是我的app.js文件，我不确定如何在其中使用socket.io并使其正常工作。任何帮助都是最好的！我已经尝试了几种不同的方式来写这篇文章，但我认为问题在于我正在使用端口做其他事情。
我需要socket.io，然后在下面使用它，但是我得到了错误。
const express = require('express');
const path = require('path');
const hbs = require('hbs');
const socket = require('socket.io');
const metho
浏览 51提问于2018-06-06得票数 3
回答已采纳
1回答
我有一个创建多个线程的类，每个线程都有一个套接字作为构造函数中的参数。
我需要同步线程，以便在给定时间只有一个线程访问套接字流。
以下是我需要的快速草稿：
class MyClass{
Socket socket;
public MyClass() {
socket = new Socket(address, port);
}
void createThread(){
Worker worker = new Worker(socket);
Thread t = new Thread(worker);
浏览 0提问于2013-12-12得票数 2
我在boost::asio中做了一个回送服务器示例。但是使用boost::make_shard会导致“未知异常”，而std::make_shared不会。请看注释行。
我正在使用visual 2017和boost 1.6 7。注释部分将崩溃，而未注释部分不会崩溃。看来boost库在boost/stage/lib中是与vs141兼容的。
#include <iostream>
#include <boost/asio.hpp>
#include <boost/make_shared.hpp>
using boost::asio::ip::tcp;
using
浏览 0提问于2018-05-13得票数 1
回答已采纳
1回答
对于我的生活，我无法让我的网页连接到节点js服务器提供socket！
当服务页面是public_html文件中的静态页面时，所有的功能都很好，但是一旦我使用了laravel视图，客户端就会恢复到长轮询，这种轮询会失败。
我甚至无法让它输出控制台上的连接消息。
服务器：
var socket = require( './public/node_modules/socket.io' );
var express = require('./public/node_modules/express');
var app = express();
var serv
浏览 3提问于2016-05-02得票数 2
回答已采纳
1回答
我目前正在开发一台服务器，它使用使用者/生产者的线程方法和阻塞集合来处理客户端，如下所示：
public class NetworkClient
{
private bool _started = false;
private int _clientId;
private readonly Socket _socket;
private static AutoResetEvent _lastMessageWasAckd = new AutoResetEvent(true);
private static BlockingCollection<by
浏览 9提问于2022-01-24得票数 0
回答已采纳
我正在使用套接字在Python上创建一个本地客户端-服务器游戏，其中服务器托管在本地网络上，网络上的客户端可以连接到服务器，前提是它们拥有服务器的IP地址。它不是专用服务器，所以它只是在客户端计算机上的另一个线程上运行。目前，客户端必须手动输入服务器的IP地址才能连接到它。我希望客户端能够在网络中搜索可用的服务器加入，但我不确定如何让服务器广播它的可用性。
这是服务器端脚本：
totalConnections = 0
port = 5555
host=socket.gethostname()
IP = socket.gethostbyname(host) #this just fetches
浏览 2提问于2020-01-29得票数 0
嗨，我正在尝试从android客户端发送数据到我的PC上的Python服务器，这里的代码我真的不知道我做错了什么，(我不确定我是否理解了tcp套接字是如何在Javascript上工作的)，我对编码是新手，当我的手机通过USB连接到PC时，我运行这个程序。
Javascript客户端：
package com.example.app;
import android.os.AsyncTask;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.widget.Button
浏览 5提问于2020-02-24得票数 0
1回答
如何使用socketIO从服务器端触发发射？我的nodejs服务器上有一个socket.on('My_Event')，我希望用.emit('My_Event')从服务器上的其他地方触发该事件。
我在这里的目标是向客户端广播一些通知数据。
服务器端- app.js
var app = express(),
server = http.createServer(app),
io = require('socket.io')(server);
io.on('connection', function(socket){
浏览 1提问于2015-03-18得票数 1
全。
我有一个问题是socket.io。在Socket.io中，它提供了socket.set/get方法来存储和检索套接字相关的值。这看起来很有用，但我有一个问题。
而不是使用socket.set(键，值)。我认为对象属性可以是另一种解决方案，比如"socketkey = value“
用户socket.set/get而不是Object属性有什么特别的好处吗？
像集群范围的复制等。提前感谢。
浏览 0提问于2014-04-21得票数 0
我想使用解释器中的原子操作在两个线程之间共享一个变量，如所述。核心数据类型的简单赋值(单字节码操作)应该是线程安全的，因为python中的GIL < 3.2。到目前为止，理论上。下面的代码可以在主模式或从模式(-m或-s)下运行。主机模式不会一直通过UDP发送数据。从属模式会创建一个线程来从udp端口读取数据，并更新每个接收到的数据包上的变量。
示例代码确实在创建时将共享变量作为参数传递给线程。我也尝试过使用全局变量或将线程本地存储传递给线程。
结果也是一样的。在read_time_master线程中，变量被赋值。但在主线程中，共享变量的值不会更新。
#!/usr/bin/env pyt
浏览 3提问于2012-11-28得票数 0
回答已采纳
1回答
所以在服务器中，我试图将一些属性绑定到套接字对象，我可以从我的客户端读取，但这只对第一个属性有效。
以下是我运行的内容
socket.isPlayer = true;
socket.isWaiting = true;
socket.playerNum = 0;
但是在客户端，我看到的是socket.isPlayer属性。任何想法发生了什么，非常感谢你的帮助。
这是我完整的服务器端文件
'use strict';
var mongoose = require('mongoose'),
PlayingGame = mongoose.model('P
浏览 0提问于2016-04-04得票数 1
我正在使用boost示例httpserver3：
我不清楚当调用new_connection_的重置方法时会发生什么
void server::start_accept()
{
new_connection_.reset(new connection(io_service_, request_handler_));
acceptor_.async_accept(new_connection_->socket(),
boost::bind(&server::handle_accept, this,
boost::asio::placeholder
浏览 2提问于2013-09-14得票数 0
回答已采纳
我正在尝试使用react原生应用程序的Socket.io，但我在客户端和服务器端之间有一些问题，我认为代码是正确的，但当单击按钮时，它不会更新状态，连接完成，我显示日志工作，我没有显示任何错误！
这是我的代码：
server/app.js
var app = require("express")();
var server = require("http").Server(app);
var io = require("socket.io")(server);
server.listen(8080);
app.get("/",
浏览 3提问于2018-12-04得票数 0
我知道如何使用Firebase编写聊天应用程序，但对如何在聊天屏幕中使用flutter实现文件共享功能一无所知。我正在寻找教程来帮助我学习和理解同样的东西。此外，该数据库不是固定的Firebase。我想和MySQL一起使用socket.io来保存聊天，因为socket.io是免费的。
我很高兴听到关于解决方案的最佳建议技术是什么。
浏览 42提问于2019-10-22得票数 1
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议
腾讯云开发者
