Python - socket一次只抓取一条消息
Python中的socket库是用于网络通信的标准库之一。它提供了一种简单而强大的方式来进行网络编程，包括创建客户端和服务器端应用程序。
在使用socket库进行网络通信时，一次只抓取一条消息可以通过以下步骤实现：
- 创建一个socket对象：使用
socket.socket()函数创建一个socket对象，可以指定通信协议（如TCP或UDP）和地址族（如IPv4或IPv6）。 - 绑定地址和端口：对于服务器端应用程序，使用
bind()方法将socket对象绑定到一个特定的IP地址和端口号上。对于客户端应用程序，可以省略此步骤。 - 监听连接请求（仅服务器端）：对于服务器端应用程序，使用
listen()方法开始监听来自客户端的连接请求。 - 接受连接（仅服务器端）：使用
accept()方法接受客户端的连接请求，并返回一个新的socket对象和客户端的地址。 - 接收消息：使用新的socket对象的
recv()方法接收客户端发送的消息。由于一次只抓取一条消息，可以设置一个合适的缓冲区大小来确保只接收一条完整的消息。 - 处理消息：对接收到的消息进行处理，可以根据具体需求进行解析、存储或其他操作。
- 发送响应（可选）：如果需要向客户端发送响应消息，可以使用新的socket对象的
send()方法发送响应。 - 关闭连接：使用新的socket对象的
close()方法关闭连接。
需要注意的是，以上步骤是基于TCP协议的示例，对于UDP协议，一次只抓取一条消息的实现方式可能会有所不同。
在Python中，可以使用socket模块来实现上述步骤。具体的代码示例和更多详细信息可以参考腾讯云的相关文档和示例代码：
- Python socket模块文档：https://docs.python.org/3/library/socket.html
- 腾讯云云服务器（CVM）产品介绍：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库 MySQL 产品介绍：https://cloud.tencent.com/product/cdb_mysql
- 腾讯云云数据库 PostgreSQL 产品介绍：https://cloud.tencent.com/product/cdb_postgresql
- 腾讯云云数据库 Redis 产品介绍：https://cloud.tencent.com/product/cdb_redis
- 腾讯云云数据库 MongoDB 产品介绍：https://cloud.tencent.com/product/cdb_mongodb
请注意，以上链接仅为示例，实际推荐的产品和链接可能因具体需求而异。
相关·内容
我有一个nodejs应用程序，可以监听客户端的消息(python应用程序)。我用于通过zmq进行通信的模式是REQ/REP模式。主应用程序应该从许多客户端获取消息。它不会回复他们，只会收到消息。问题是主应用程序只能获得第一条消息，下一条消息没有显示在nodejs应用程序控制台中。
换句话说，每次启动nodejs应用程序时，我只收到一条消息。
这是我的代码：
Nodejs应用程序
var responder = zmq.socket('rep');
responder.on('message', function(request) {
console.lo
浏览 1提问于2014-02-07得票数 1
回答已采纳
我的套接字发送第一条消息，但之后不发送任何消息。
服务器中的输出：
What do you want to send?
lol
客户端接收：
From localhost got message:
lol
然后它就不想再发送任何东西了。我不再打印what do you want to send了。
我的代码：
server.py文件：
#!/usr/bin/python3
import socket
# create a socket object
serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# get
浏览 2提问于2018-10-22得票数 2
1回答
假设我在python中创建了一个UDP套接字，然后使用以下命令发送一条消息：
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.sendto(MESSAGE, (DEST_IP, DEST_PORT))
如何找出我的消息是从哪个源端口发送的？
(我不想将套接字绑定到任何特定端口。但我如何找出哪个源端口是用来发送消息的？)
浏览 0提问于2013-11-21得票数 3
2回答
我正在使用java和socket来实现客户机/服务器应用程序的通信。
我想向服务器发送一条消息，如下所示：
is = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
pw = new PrintWriter(socket.getOutputStream());
pw.println("MESSAGE");
pw.flush();
这很有效，但在那之后，我试图发送另一条消息
pw.println("SECOND MESSAGE
浏览 1提问于2014-02-27得票数 0
1回答
我有一个具体的问题，错误“不能设置标题后，他们被发送”。
代码是这个：
create: (request, response, next) ->
socket = @app.socket
#
# This method will be used to call the right method inside
# the emails service.
data = JSON.stringify(
Object.assign request.body.data, method: 'server'
)
socket.send data
socket.on '
浏览 0提问于2016-02-01得票数 1
回答已采纳
来自Python的我正在尝试使用JavaScript和node.js来实现类似的结果。 我正在尝试通过网络发送一条简单的TCP消息。在Python中，我将通过以下方式实现这一点： import socket
device_ip = '192.168.0.10'
device_port = 20000
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.settimeout(5)
s.connect((device_ip, device_port))
command = ('Message to be s
浏览 15提问于2020-07-11得票数 0
1回答
假设我们有：
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
data = s.recv(1024)
如果我们收到消息，但最后一条消息不是1024字节，该怎么办？我们还会收到它，还是会永远等下去？如果最后一条消息没有填满缓冲区，该如何接收？
在Node.js中，流具有“刷新”行为，其中flush是内部调用的(不确定何时调用)，如下所示：
浏览 0提问于2019-03-10得票数 0
1回答
我有许多TCP客户端需要向服务器发送多条消息。在服务器端，我写道：
def listenConnections():
thread_recieve = Thread(target=recieveInstruction)
while(1):
lstn = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# port = int(sys.argv[1]) # server port number
lstn.bind(('IP', PORT))
浏览 3提问于2014-08-20得票数 1
回答已采纳
这将在没有.once调用的情况下工作。
我正在尝试从服务器端代码发送一条消息
io.on('connect', function (socket) { socket.once('connect', function() { socket.emit('mydata', { feed: result});
但是，除非我删除第二行，否则我在客户端什么也得不到。我也尝试了socket.once('mydata'，{ feed: result})，但是：
throw new TypeError('listener must be a
浏览 0提问于2016-03-25得票数 3
回答已采纳
在broswer中，我描述了一个频道：
var socket = new WebSocket("ws://127.0.0.1:7379/.json");
socket.onopen = function() {
socket.send(JSON.stringify(["SUBSCRIBE", "mychannel"]));
};
socket.onmessage = function(evt)
{
console.log(evt.data);
};
在python中，我可以发布一条消息，并且broswer接收它，代码是：
impo
浏览 17提问于2022-01-03得票数 0
回答已采纳
我在一个NodeJS +类型记录项目中使用NodeJS，在这个项目中，客户端向服务器发送一条消息和相同的消息，并使用套接字发送回客户端。但是，每次我向服务器发送新消息时，服务器发送回消息的次数会增加1--这不是我编程它的方式。例如，当我第一次发送消息"x“时，服务器返回消息"x”。下一次我发送消息时，服务器将返回该消息两次。下一次它会发生三次，直到页面被刷新，当它返回到一个页面时。我不知道哪里出问题了。下面是代码：
客户端：
$("#send").click(function(){
alert("Sending : " + $(&
浏览 1提问于2013-12-21得票数 2
回答已采纳
2回答
我制作客户端-服务器应用程序。它看起来像这样： 客户端 import socket
host = '127.0.0.1'
port = 1338
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((host, port))
while True:
st = input("Your message: ")
byt = st.encode()
s.send(byt) 服务器 import socket
host = ''
port = 1338
浏览 51提问于2021-04-25得票数 0
回答已采纳
设置：
我正在使用Spring Integration从消息队列中抓取消息。消息以XML格式出现，我的服务激活器调用一个名为parseCustPaymentXML的方法，处理该XML消息，并将其存储在Java对象中。然后，从parseCustPaymentXML调用另一个名为processCustPayment的方法，该方法获取Java对象并将它们插入到数据库中。下面是我如何设置我的入站JMS和服务激活器...
<int:channel id="jmsInChannel" />
<int-jms:message-driven-channel-adapter
浏览 0提问于2015-06-04得票数 0
我通过套接字将鼠标坐标从python服务器发送到python客户机。每次在服务器上捕获鼠标移动事件时，都会发送鼠标坐标，这意味着通常(每秒十几次)。
问题是当我在不同的主机上使用python服务器和python客户端时。然后，只向客户端传递部分消息。例如，3条第一条消息被传递，4条消息没有被传递，4条消息被传递等等。
当服务器和客户端在同一个主机(本地主机)上时，一切都很好。
当服务器和客户端在不同的主机上时，一切都很好，但不是python客户机，而是使用标准的从服务器读取消息。
我注意到，当我使用time.sleep(0.4)在发送的每条消息之间中断时，所有消息都会被传递。问题是我需要实时的
浏览 6提问于2016-10-08得票数 2
回答已采纳
1回答
var connectionHandler = function(socket) {
var player = null;
socket.on('login', function(data) {
player = {
data: okeyServer.playerJoin(data),
socket: socket
};
socket.emit('welcome');
});
socket.on('info server', function(data) {
v
浏览 3提问于2013-11-27得票数 0
回答已采纳
我有简单的python服务器和客户端。
服务器：
import SocketServer
import threading
class MyTCPHandler(SocketServer.BaseRequestHandler):
def handle(self):
self.data = self.request.recv(1024).strip()
print str(self.client_address[0]) + " wrote: "
print self.data
self.request.s
浏览 1提问于2011-12-25得票数 16
回答已采纳
我已经写了一个类，它已经允许我使用套接字连接两个设备，我还实现了让彼此发送消息的能力。我通过一个DataInputStream获得接收到的消息，它在while(true){}循环中不断地检查消息。我记录了这些消息，但它们对整个控制台都是垃圾邮件。因此，我添加了一个名为lastMsg的变量，用于检查当前消息是否是最后接收到的消息，如果是，则不会打印该消息，因此该消息将只被记录一次。问题是，当用户发送两条相同的消息时，显然只会记录第一条消息。
那么，有没有其他方法来检查一条消息是发送了两次，还是几秒钟前发送的是同一条消息？
我用来检查收到消息的代码：
public void run() {
浏览 1提问于2017-02-27得票数 0
2回答
因此，我试图制作一个应用程序，用户客户端将发送消息到服务器。我希望找到一种方法来区分一条消息和另一条消息，这样我就可以在sock.recv(1)上循环，直到我知道消息已经结束并保存该消息，然后我可以转到下一条消息。我可能完全走错了路，但我不知道如何用TCP流来实现这一点。现在我给user.py买了这个
import socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(("localhost", 1234))
while True:
resp = someEventTha
浏览 0提问于2018-10-23得票数 1
回答已采纳
当我使用ZeroMQ时，我有一个关闭python应用程序的问题。首先，我连接到一个没有运行的服务器！
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket_id = randomID()
socket.setsockopt(zmq.IDENTITY, socket_id)
socket.connect("tcp://dead_server")
poller = zmq.Poller()
poller.register(socket, zmq.POLLIN)
并发送我的信息
socket.send(msg)
浏览 0提问于2013-06-17得票数 7
回答已采纳
1回答
我想通过TCP连接两个程序。我的主程序是用Qt编写的，需要与另一个用Python编写的程序对话。我考虑使用TCP套接字和Google的protobuf来交换消息。在Qt中，我使用了一个QTcpSocket，一旦它的readyRead-信号被触发，它就接受连接并从流中读取。在python中，我也使用tcp套接字发送消息。
只要没有任何一方被杀死，这种方法就能很好地工作。目前，python端正在向C++端发送消息。(socket.send(str(id)+"\ņ"))每次发送后，我都会检查异常(对等设备重置连接、管道断开...)查看是否收到该消息。如果我终止C++程序，那么从pyt
浏览 1提问于2013-08-15得票数 0
我有一个基本的python套接字，如下所示：
server.py
import socket
ip = '192.168.2.231'
port = 2005
addr = (ip, port)
serv_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
serv_socket.bind(addr)
serv_socket.listen(2)
con, cliente = serv_socket.accept()
receive = con.recv(1024)
if receive == '
浏览 7提问于2018-02-19得票数 0
从几个月以来，我一直在自学python，并最终学习了Socket编程。作为一个教科书练习，我应该设计一个半双工聊天系统。下面是密码。第一个请求和响应很好，但是每次我尝试从客户端发送第二条消息时，服务器似乎都挂起了。该程序基于TCP。
我怀疑，由于每次需要发送新消息时都调用ss.accept()，因此正在创建一个新线程，但由于我只从客户端调用了一个sc.connect()，可能是服务器端的新连接挂起了无限时间。
作为一条线索:我在while循环之外调用了ss.accept()，即只进行了一个连接，并且一遍又一遍地听数据，但是循环中，会话工作得很好
请有人看一看代码，并帮助我了解到底是哪里的问题。
浏览 0提问于2013-08-27得票数 1
回答已采纳
我希望每隔1秒从服务器向客户端发送一条消息，在发送消息之前将字符串“send clock”写入控制台。
但是，客户端没有收到“时钟”消息。
我已经得到了回声消息工作正常，所以这不是一个连接问题。
如何每隔1秒发送一条消息？
服务器代码(Python)：
import threading
import time
import socketio
import eventlet
socket = socketio.Server(async_mode='eventlet')
app = socketio.WSGIApp(socket)
@socket.on('echo
浏览 5提问于2020-05-03得票数 1
我有困难的时候，抓取和打印的数据，成功地推送到电线上。我建立了一个简单的推拉体系结构，其中Metatrader 4充当producer，Python后端充当consumer。
当涉及到抓取和打印数据时，我无法实现。
这就是我的推送实例，它运行得很好：
Metatrader 4 zeroMQ push实例：
#include <Zmq/Zmq.mqh>
// EA plot settings
extern string PROJECT_NAME = "Dashex.Feeder";
extern string ZEROMQ_PROTOCOL = "tcp&
浏览 2提问于2019-12-01得票数 0
回答已采纳
我正在尝试在python中创建一个套接字客户机。我可以发送第一条消息，没有错误，但是当我试图发送第二条消息时，它就停止了。
import socket , time
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
def OpenConnection(IP,PORT):
global sock
sock.connect((IP, PORT))
def SendMessage(StringMessage):
global sock
print "Step 1"
soc
浏览 4提问于2014-03-19得票数 0
回答已采纳
我正在尝试通过TCP/IP发送消息，所有消息都在主机上。这是有效的，尽管出于某些原因，套接字只需要为客户端上的每条新消息重新实例化。例如，下面是一个基本客户端，它发送三个单独的消息：
import socket
host = '127.0.0.1'
class Client:
def __init__(self):
self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
def connect(self):
self.sock.connect((host,
浏览 0提问于2016-06-21得票数 0
每次我从另一个组件发出消息时，我都无法获得完整的消息列表。以下是钩子和视图组件：
export function useChat() {
const [messages, setMessages] = useState([]);
useEffect(() => {
const socket = openSocket("http://localhost:3003");
socket.on("chat message", msg => {
const newState = update(messages, { $pu
浏览 3提问于2019-02-14得票数 13
回答已采纳
3回答
我有一个客户端程序，它向服务器发送在控制台中输入的消息。根据一些建议，我介绍了使用Socket.checkError()检查封闭套接字。然而，由于某些原因，它只在第二次尝试发送消息失败后才表示错误。
我的代码：
BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
while (true)
try (
Socket clientSocket = new Socket(hostname, port);
PrintWri
浏览 2提问于2016-01-06得票数 2
回答已采纳
我想让Raspberry Pi同时从多个带有TCP套接字的Mbed微控制器收集数据。现在我有两个微控制器以固定的时间间隔发送不同的数据包。微控制器在任何时候都会收到一条错误消息，因此在连续3次发送失败后，它将关闭并重新打开其套接字。使用我目前的代码，我有100%的数据包传输成功，只有一个微控制器供电，但使用第二个发送数据包，它可能会短暂地工作，但随后将开始看到丢失的数据包和偶尔的错误。
#The server code is
import sys
import socket
from threading import Thread
from socketserver import Thr
浏览 0提问于2021-11-16得票数 0
我用Python制作了一个游戏，游戏由几条蛇组成，每条蛇都由一台不同的计算机控制。每台计算机向服务器计算机发送蛇被指向的角度。
问题是命令
client_mess = client_socket.recv(1024)
极大地抑制了服务器操作，使游戏运行得非常慢。我正在寻找一种使用用户发送的用户消息的方法，如果自上一条消息以来没有发送任何消息，服务器将使用前一条消息而不等待另一条消息。
以下是我代码的相关部分：
服务器：
server_socket = socket.socket()
server_socket.bind(('0.0.0.0', 5050))
server_soc
浏览 4提问于2021-08-15得票数 0
回答已采纳
我将通过PHP创建的一个套接字将多条消息(每条消息动态创建)写到设备上。第一条消息总是通过，但后续消息不通过。为了帮助我调试，请让我知道这个例子是否有问题：
$socket= socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($socket, $ip, $port);
socket_write($socket, "message 1\r");
socket_write($socket, "message 2\r");
浏览 1提问于2012-05-11得票数 3
回答已采纳
2回答
因此，我正在开发一个Python IRC框架，并使用Python的socket模块。我想用Twisted吗？不，不是真的。
无论如何，我有一个无限循环来读取和处理来自socket.recv(xxxx)的数据，而xxxx在这种情况下实际上是无关紧要的。我使用str.split("\r\n")将收到的数据拆分成消息，并逐个进行处理。
我的问题是，我必须在socket.recv()中设置一个特定的“读取大小”，以定义从套接字读取多少数据。当我接收到突发数据时(例如，当我连接到IRC服务器并接收MOTD.etc时)，总会有一条消息跨越两次“读取”套接字(即在一个socket.recv(
浏览 0提问于2011-10-04得票数 1
回答已采纳
1回答
我用python制作了一个小型服务器，它可以监听端口4444，当我连接到telnet时，我可以发送消息，服务器可以正确地显示消息。我只有一个问题:当我试图“解析”telnet消息时，我无法正确地完成它。事实上，如果我发送的消息是“屏幕截图”，如果使用If output==“屏幕快照”，服务器会在控制台上打印一条消息。这不管用。这是我的源代码，我对Python和网络编程很陌生。预先感谢**即使我在IF语句中使用==也是相同的** Coogle
源
import head
print("SockShot Server Starting\n")
sock=head.Server(&#
浏览 2提问于2015-07-31得票数 0
1回答
我已经创建了一个python服务器，我使用node.js套接字模块在浏览器和tcp服务器之间进行通信。它们按层次连接起来，比如: Browser-> Node.js ->Python浏览器<- Node.js <-Python服务器--我可以将Node.js连接到TCP，我可以发送消息，但在发送第一条消息后，我不能从Node.js发送任何消息到Tcp，类似地，在我从Tcp发送消息到Node.js之后，我不能在第一条消息之后发送消息。我的Node.js代码：
var http = require('http');
var mysql = require(&
浏览 3提问于2013-09-21得票数 0
我对nodejs有意见。我有一个python扭曲的tcp服务器，当我尝试这样做时：
var socket = server.net.createConnection(server.controllerPort,
server.controllerHost);
socket.on('data', function(data) {
log('RESPONSE: ' + data);
});
socket.on('connect', function() {
浏览 1提问于2014-05-12得票数 2
回答已采纳
我有一个用Java实现的客户机，一个用客户机实现的服务器。客户机向服务器发送一条消息(字符串)，如“嵌套:1:2”，服务器对输入的含义进行解码，以创建二进制数据并将其发送回客户端。
这是Python服务器代码。
class MyTCPHandler(SocketServer.BaseRequestHandler):
def handle(self):
# self.data has the data
(name, index, n) = self.data.split(":")
m = int(n)
i
浏览 1提问于2015-04-13得票数 0
回答已采纳
我对套接字编程非常陌生，我想知道为什么客户端在我向服务器发送3条消息后停止响应。基本上，我发送一条消息两次，服务器响应客户端。第三次，客户端无限运行，服务器没有收到任何东西。
这和过载有关系吗？这是如何工作的，特别是使用socket.listen()
下面是供参考的代码：
client.py
# Import socket module
import socket
# Create a socket object
s = socket.socket()
# Define the port on which you want to co
浏览 0提问于2020-02-28得票数 0
标题解释了一切。我编写了Java代码，为python服务器发送消息，但是每次发送第一条消息，因为每次java再次连接到服务器时，服务器一直在等待来自我第一次发送的第一个客户端的下一条消息。
服务器如何从所有连接的客户端获取消息？而不仅仅是从一个？
我的python服务器：
server = socket.socket()
server.bind((socket.gethostname(), 4786))
server.listen(5)
(client, (ipNum, portNum)) = server.accept()
print("C
浏览 1提问于2020-12-11得票数 1
回答已采纳
我正在处理Python2中的套接字编程，并在服务器脚本中试用select()。当我有服务器的以下代码时：
print('Server started in port {}.'.format(self.port))
server_socket = socket.socket()
server_socket.bind((self.address, self.port))
server_socket.listen(5)
client_sockets = [server_socket]
while True:
for s in client_sockets:
浏览 0提问于2019-02-27得票数 0
回答已采纳
3回答
我有一个本地server-class，它向client-class发送两个字符串消息(“第一条消息”和“第二条消息”)。在客户端类中，我想将它们放入来自BufferedReader的ArrayList代码中，然后打印出来。
void go () throws IOException {
Socket socket = new Socket("127.0.0.1",4242);
InputStreamReader streamReader = new InputStreamReader(socket.getInputStream());
BufferedR
浏览 4提问于2016-09-18得票数 4
回答已采纳
1回答
每当客户端打开远程管理时，轮询都应该从服务器( Admin )开始。当轮询启动时，admin可以向客户端发送消息，打开VPN连接，然后将VPN生成的IP地址发回管理员。这就是我现在试图实现的目标，我正在尝试发送静态IP值，但稍后我将包括VPN所需的操作。所以基本上我想在客户端打开远程管理，然后管理员发送消息打开VPN，然后从客户端接收生成的ip时，用admin启动轮询。我已经使用socket.io通过节点(服务器)和python (客户端)创建了套接字连接，在post路由内重新连接之后，我无法打印来自客户端的消息。再次，当我重新启动服务器时，它开始工作，但是当客户端断开并再次连接时，post路
浏览 1提问于2022-05-03得票数 0
#!/usr/bin/env python
import socket
clientsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
clientsocket.connect(('192.168.1.123', 5162))
clientsocket.send('getval.1')
clientsocket.close
clientsocket.bind(('192.168.1.124', 5163))
clientsocket.listen(1)
while True:
浏览 0提问于2016-11-06得票数 4
回答已采纳
3回答
public class Main {
private static Socket socket;
public static void main(String[] args) {
try {
int port = 13579;
ServerSocket serverSocket = new ServerSocket(port);
System.out.println("Servidor Iniciado escuchando al puerto " + port);
while (true) {
浏览 1提问于2014-05-30得票数 0
回答已采纳
我正在测试Python服务器。它使用localhost作为服务器和客户端，如预期的那样工作，但是当我在不同的计算机上进行测试时，我得到了
Errno 54连接由对等重置大约20% - 80%的时间，这取决于我一次生成多少客户端线程。为什么？
代码片段
服务器侦听：
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind((self.interface, self.port))
sock.listen(5)
服务器循环永远，接受客户端连接，产生新线程：
while True:
(clientsock, (ip,
浏览 0提问于2015-05-01得票数 2
1回答
我已经初始化了一个WebSocket连接，并且我正在监听流，我将其定义为asBroadcastStream，因此它不会返回侦听来自同一流的事件的stream has already been listened to。
流正在多次侦听同一条消息。
例如，在第一条消息流上打印data 1次
第二条消息流打印data 2次
第三条消息流打印data 3次
..。诸若此类。
class NotificationController {
static final NotificationController _singleton =
NotificationController._int
浏览 10提问于2022-08-19得票数 0
我一直试图使用套接字在python中创建消息传递服务。我编写了代码来承载两个连接，并允许其中一个使用用户名和host_addr向另一个连接发送消息。
但是，每次我试图连接第二个客户端并从第一个客户端发送一条消息时，都会收到以下错误。
ConnectionResetError: [Errno 54] Connection reset by peer
Server.py
import socket
import _thread as thread
HOST = "127.0.0.1" # Standard loopback interface address (localhos
浏览 3提问于2022-10-31得票数 0
1回答
我想在两台机器之间创建一个聊天程序。我使用的是具有IP地址192.168.0.5的机器一号，我可以成功地将一条消息发送到机器2 192.168.0.2，然后从机器二向机器1发送一条消息。
但是，在从任何一台机器进行第二次发送尝试时，我遇到了一个问题(注意到在第二次发送之前，我在等待初始发送的响应)，声称IP地址已经在使用或连接被拒绝，如何更改这一点，以便可以发送定义数量的选项？
我理解以下代码不是发送和接收多条消息的最有效方式，这将是对for循环的某种描述。例如，for sendAndRecieve in range(0,5)。
这两台机器使用通过交换机运行的以太网电缆连接，代码同时运行。
机
浏览 1提问于2014-03-13得票数 0
在开发我的angularjs (BTFord库)和NodeJS Socket.IO之间的聊天应用程序时，我实际上遇到了一个问题……
实际上，我需要用户A向用户B发送一条消息。-如果我在node中登录消息，它将正常工作，并且只发送一次。详细说明:在angular js中，事件(“message”)被调用了3到4次，而我需要发送3到4次消息
这对我来说是个问题。我只需要接收一次消息。这有什么问题吗？
感谢你的预支
浏览 3提问于2014-09-09得票数 0
1回答
我正在Kotlin上编写一个应用程序，它使用Python后端服务器，我似乎很难将它们连接在一起。
在python上我使用
from socket import socket, AF_INET, SOCK_STREAM
from threading import Thread
def handle_connection(c):
amount = int(c.recv(2048).decode("utf8"))
for i in range(amount):
print(c.recv(2048).decode("utf8"))
cla
浏览 2提问于2021-09-14得票数 0
回答已采纳
3回答
我想使用套接字在服务器和客户端之间创建一个简单的通信。客户端应该发送一条消息，然后服务器向客户端发送一条消息。
这是我的客户端代码：
import socket
s = socket.socket()
HOST = '127.0.0.1'
s.connect((HOST, 1234))
s.send('Hi')
print ('Client send')
print s.recv(1024)
s.close
这是我的服务器的代码：
import socket
s = socket.socket()
HOST = '127.0.0.1
浏览 0提问于2015-03-11得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
