1回答
如何从聊天服务器与多个客户端聊天
、、、、
这些问题：
如何与os控制台中的聊天服务器上的任何用户客户端聊天？
有谁能帮我找到多个客户的工作机制吗？作业机制由os终端控制台控制。
与服务器聊天
启动聊天服务器，并与客户端建立聊天连接。
$ nc -v 127.0.0.1 4444
双重客户如下：
==================== |----> [client1: ('127.0.0.1', 37748)]
| Server (Console) |<----|
==================== |----> [client2: ('12
浏览 3提问于2016-06-22得票数 0
我正在尝试让我的程序，它使用Pika，在失败时不断重试连接到RabbitMQ。根据我对Pika文档的了解，有一个SimpleReconnectionStrategy类可以用来实现这一点，但它似乎工作得不是很好。
strategy = pika.SimpleReconnectionStrategy()
parameters = pika.ConnectionParameters(server)
self.connection = pika.AsyncoreConnection(parameters, True, strategy)
self.channel = s
浏览 0提问于2011-04-11得票数 5
3回答
是否可以通过相同的asyncore与dbus集成main loop？
通常，DBus集成是通过glib主循环完成的：asyncore是否可以集成这个主循环，或者让dbus使用asyncore？
浏览 4提问于2010-01-27得票数 6
回答已采纳
我编译了Python3.6并运行了测试，但其中有两个失败了：
======================================================================
FAIL: test_handle_expt (test.test_asyncore.TestAPI_UseIPv4Poll)
----------------------------------------------------------------------
Traceback (most recent call last):
File "/Users/andrei/Py
浏览 1提问于2017-02-25得票数 0
回答已采纳
我需要使用Python为一个简单的请求/响应无状态服务器编写一个简单的程序(不允许线程)。客户端发送请求，服务器返回响应。此外，它还需要处理多个事务，这是我使用的简单方法：
import asyncore, socket
class Server(asyncore.dispatcher):
def __init__(self, host, port):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
sel
浏览 17提问于2017-06-30得票数 0
我只能把数据发送到一个连接上，就像我能做的那样？
服务器：
import asyncore, socket, threading
class EchoHandler(asyncore.dispatcher_with_send):
def __init__(self,sock):
asyncore.dispatcher.__init__(self,sock=sock);
self.out_buffer = ''
def handle_read(self):
datos = self.recv(1024);
浏览 1提问于2013-07-30得票数 0
2回答
异步核心超时
、、
简单的异步http客户端，长时间挂起与不可用的网站。
例如，在站点www.evtur.ru上，它会等待很长时间，10分钟或更长时间。
我找不到如何最小化超时的方法，例如，有没有可能在5秒内超时？
# coding=utf-8
import asyncore
import string, socket
import StringIO
import mimetools, urlparse
class AsyncHTTP(asyncore.dispatcher):
# HTTP requestor
def __init__(self, uri):
asyncore
浏览 4提问于2011-12-15得票数 4
2回答
我正在编写一个简单的socket服务器，我想跟踪客户端的状态(身份验证等)。每次调用handle_read()时，我都不知道关于那个特定客户机的任何事情。如果我知道客户的ID什么的话会有帮助的。这是我到目前为止所知道的：
import asyncore
import socket
class EchoHandler(asyncore.dispatcher_with_send):
def handle_read(self):
data = self.recv(8192)
self.send(data)
class EchoServer(asyncor
浏览 2提问于2012-05-16得票数 2
回答已采纳
我不明白客户端套接字如何关闭连接。
import asyncore
import socket
class TCPClientHandle(asyncore.dispatcher):
def __init__(self, sock, server):
asyncore.dispatcher.__init__(self, sock)
self.server = server
.....
def handle_close(self):
print 'Client: handle_close'
浏览 1提问于2013-02-06得票数 0
回答已采纳
我使用的是TCP 4.4.6，我想将运营商更改为PySNMP。
这意味着我希望使用TCP协议轮询SNMP数据。
当我将运营商切换到TCP时，我收到以下错误：
File "send-trap-over-ipv4-and-ipv6.py", line 76, in <module>
transportDispatcher.runDispatcher()
File "/usr/local/lib/python2.7/dist-packages/pysnmp/carrier/asyncore/dispatch.py", line
浏览 35提问于2019-11-19得票数 0
我正在尝试编写一个UDP服务器，该服务器使用asyncore.dispatcher_with_send回显数据
问题是，当我设置缓冲区并调用self.send(self.buffer)时，它似乎调用了handle_close并关闭了套接字。
import asyncore, socket,
class Server(asyncore.dispatcher_with_send):
def __init__(self):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.S
浏览 4提问于2017-05-26得票数 0
回答已采纳
我正在尝试利用multiprocessing模块的客户机/服务器架构来促进我的Python脚本之间的通信。我希望能够使用asyncore实现一个独立于主事件循环的连接侦听器。我该怎么做呢？
虽然没有关于如何做到这一点的外部文档，但我已经尝试使用multiprocessing.Listener中的侦听器套接字来构造一个基本的asyncore.dispatcher
import asyncore
import socket
from multiprocessing.connection import Listener, Client
class ConnectionListener(asynco
浏览 8提问于2013-03-18得票数 2
1回答
由于某些原因，下一个初级程序只在第二次连接客户端和服务器。所以每次重启服务器后。谁能解释一下这种行为的原因以及如何解决这个问题？也许是因为asyncore只在服务器端使用？(Windows 7，Python 3)提前谢谢你！
С客户端：
import socket
sock = socket.socket()
host = 'localhost'
port = 8081
tempr = port
sock.connect((host,port))
服务器：
import asyncore
import socket
import time
class EchoHandle
浏览 0提问于2017-11-07得票数 0
我遵循了一些使用asyncore 的示例代码，只是为asyncore.loop设置了timeout值，如下面的完整示例所示：
import smtpd
import asyncore
class CustomSMTPServer(smtpd.SMTPServer):
def process_message(self, peer, mailfrom, rcpttos, data):
print 'Receiving message from:', peer
print 'Message addressed from:',
浏览 7提问于2013-01-24得票数 0
回答已采纳
1回答
当我尝试强制断开用户与我的自定义Python服务器的连接时，我得到了一个崩溃错误。我正在使用asyncore和asynchat类。
但是当我想要像这样强制断开连接时
asynchat.async_chat.close (self)
我得到了这个错误：
asyncore.loop()
File "/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/asyncore.py", line 216, in loop
poll_fun(timeout, map)
File "/Librar
浏览 0提问于2012-06-08得票数 2
回答已采纳
1回答
Cassandra 2.1.15.1403 | DSE 4.8.9
测试的Cassandra驱动程序: 2.1.2和3.1.7
我们正在使用python脚本迁移其中一个表中的一些数据。一旦完成此操作，我们将使用以下命令关闭连接：
if (None != self.session):
self.session.shutdown()
if (None != self.cluster):
self.cluster.shutdown()
在集群关机时，我们会得到以下异常：
DEBUG: Closed socket to 127.0.0.1
DEBUG: Asyncore event l
浏览 1提问于2018-04-12得票数 1
我试着在GAE上使用pyDNS。
在Base.py中有import asyncore
这就是我所得到的：
File "/base/data/home/apps/myapp/lib/DNS/Base.py", line 14, in <module>
import asyncore
File "/base/data/home/runtimes/python27/python27_dist/lib/python2.7/asyncore.py", line 608, in <module>
import fcntl
Imp
浏览 0提问于2016-04-22得票数 0
2回答
我正在尝试学习asyncore模块。所以我决定开发一个聊天程序。我必须同时收听网络和广播udp数据包。但问题是，当用户键入消息时，用户无法看到其他用户发送的其他消息。我该怎么办？我的代码：
#!/usr/bin/python
# -*- coding: utf-8 -*-
import asyncore
import socket
class Listener(asyncore.dispatcher):
def __init__(self, port):
asyncore.dispatcher.__init__(self)
self.port = p
浏览 0提问于2011-09-06得票数 7
回答已采纳
晚上好，这是我第一次在这个网站上，在过去的3个月里，我一直在为我的工作编写一个基于python的用户监控系统，我几乎完成了我的第一个版本。但是，我在控制要连接到哪台计算机时遇到了问题。
如果我运行我放在这篇文章中的两个示例代码，我可以接收客户端并通过服务器向客户端发送命令，但一次只能发送一个客户端，并且服务器指示我可以发送到哪个客户端以及下一个是哪个客户端。我确定问题出在“服务器端，但我不确定如何解决这个问题，谷歌搜索没有找到任何人尝试过这一点。”
我在这篇文章中附上了客户端和服务器端的网络代码。
客户端：
import asyncore
import socket
import sys
do
浏览 2提问于2012-09-14得票数 0
回答已采纳
1回答
我在python中实现了一个基于异步的IRC机器人，并且在捕获异步分派类方法中出现的异常时遇到了困难。下面是我的最小示例：
#!/usr/bin/env python
import asyncore
import socket
import sys
class foo (asyncore.dispatcher):
def __init__ (self, host, port):
asyncore.dispatcher.__init__ (self)
self.create_socket (socket.AF_INET, socket.SOCK_STRE
浏览 0提问于2014-05-12得票数 2
回答已采纳
import asyncore
class HTTPClient(asyncore.dispatcher):
def __init__(self, host, path):
asyncore.dispatcher.__init__(self)
self.create_socket()
self.connect( (host, 80) )
self.buffer = bytes('GET %s HTTP/1.0\r\nHost: %s\r\n\r\n' %
浏览 6提问于2013-11-13得票数 0
有没有办法检查在asyncore中是否建立了连接？
调用asyncore.loop()后，如何断开服务器之间的通信？
我能简单地调用close()吗？
浏览 3提问于2010-11-11得票数 1
回答已采纳
1回答
所以我的情况是，我已经加载了一个以上的类，我从asynchat创建了这个子类，但是我只想运行其中一个子类。当然，当我调用asyncore.loop()时，这是行不通的，因为它们都开始了。有没有办法让他们中的一个开始跑？
编辑：--我认为这与可以传递给asyncore.loop的map参数有关，但我无法让它工作。
edit2:，我知道了。基本上，我做了以下几点：
asyncore.loop(map=my_instance._map)
浏览 5提问于2009-07-09得票数 0
回答已采纳
我在使用带有AF_UNIX套接字的异步内核时遇到一些问题。这段代码
import asyncore, socket, os
class testselect(asyncore.dispatcher):
path = '/tmp/mysocket'
def __init__(self):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_UNIX, socket.SOCK_DGRAM)
self.bind(self.path)
浏览 1提问于2011-05-13得票数 3
回答已采纳
当我尝试运行我在Windows上编写的python (3.4.3)程序时，我多次收到以下错误消息，直到出现最大递归深度错误：
File "C:\Anaconda3\lib\asyncore.py", line 411, in __getattr__
File "C:\Anaconda3\lib\asyncore.py", line 411, in __getattr__
File "C:\Anaconda3\lib\asyncore.py", line 411, in __getattr__
retattr = getattr(self.sock
浏览 6提问于2015-05-25得票数 0
1回答
我有个项目。它需要部署UDP服务器和Django服务器。
我知道如何部署Django服务器。它只是和nginx和uwsgi建立在一起。它将实现我的要求。
但我不知道如何部署UDP服务器。这是我的UDP服务器的代码：
import asyncore
import socket
class EchoHandler(asyncore.dispatcher_with_send):
def handle_read(self):
data = self.recv(8192)
if data:
self.send(data)
class
浏览 3提问于2015-09-01得票数 0
回答已采纳
1回答
下面是一个简单的客户机，它连接并发送一条文本消息：
class Client(asyncore.dispatcher):
def __init__(self, host, port):
asyncore.dispatcher.__init__(self)
self.create_socket()
self.connect( (host, port) )
self.buffer = bytes("hello world", 'ascii')
def handle_connect(s
浏览 0提问于2016-06-03得票数 3
回答已采纳
1回答
我稍微修改了代码() (添加了类AsyncEventLoop)
import socket,asyncore
import threading
class forwarder(asyncore.dispatcher):
def __init__(self, ip, port, remoteip,remoteport,backlog=5):
asyncore.dispatcher.__init__(self)
self.remoteip=remoteip
self.remoteport=remoteport
self.cr
浏览 5提问于2012-10-09得票数 1
在组件的基础上，我用授权等方式编写了自己的SMTP服务器.我最不需要做的事情是在新线程中添加消息解析。
因此，我的组件由两个类组成：SMTPServer和SMTPChannel。它在一个线程中完美地工作，如下所示：
def handle_accept(self):
pair = self.accept()
if pair is not None:
conn, addr = pair
logging.info('Incoming connection from ' + str(addr))
channel =
浏览 4提问于2015-05-27得票数 0
回答已采纳
2回答
我试图创建一个程序，允许许多客户端同时连接到1台服务器。这些连接应该是服务器端的交互式连接，这意味着在客户端连接之后，我可以从服务器向客户端发送请求。
下面的异步示例代码简单地返回回显，我需要一种交互式访问每个会话的方式，而不是回显。在我决定与之互动之前，我会以某种方式了解每一种联系。如果我有100个会话，我希望选择一个特定的会话，或者选择所有的会话，或者选择其中的一个子集来发送命令。此外，我也不能100%肯定异步核心库是这里的方法，任何帮助都是值得赞赏的。
import asyncore
import socket
class EchoHandler(asyncore.dispatcher
浏览 4提问于2014-06-18得票数 1
回答已采纳
2回答
当我使用client1 = HTTPClient('192.168.1.2'，'3')时，它只起作用，但当我使用这两种方法时: client1 = HTTPClient('192.168.1.2'，'3') client2 = HTTPClient('192.168.1.3'，'3')
然后整个事情变得非常缓慢，有时其中一个失败了。如何确保client1和client2连接+发送的足够快？
import asyncore, socket
class HTTPClient(asyncore.disp
浏览 3提问于2014-04-14得票数 5
回答已采纳
我正在努力学习如何使用套接字和有用的异步后端。我从python开始使用异步核心。在阅读了各种在线帖子之后，我编写了一个非常简单的聊天服务器和连接客户端，如下所示。
好像很管用。我打开python交互式会话并键入
> import chatserver
> server = chatserver.EchoServer('localhost', 7667)
> server.serve()
然后，我打开另一个IPython交互会话并键入
> import chatserver
> cxn = chatserver.Connection()
> c
浏览 3提问于2012-12-31得票数 2
回答已采纳
self.handlers.append(ConnHandler(sock，self.handlers))我是python的新手，我试着写一个简单的套接字服务器来测试并更好地了解这门语言。
import asyncore
import socket
import json
class ConnHandler(asyncore.dispatcher_with_send):
def __init__(self, conn, handlerlist):
asyncore.dispatcher_with_send.__init__(self, conn)
s
浏览 9提问于2015-08-20得票数 0
1回答
我制作了这个基本客户端来适应自己的异步核心。
import asyncore, socket
class TestClient(asyncore.dispatcher):
def __init__(self, host, port):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((host, port))
self.buffer = "madonna&#
浏览 1提问于2013-08-29得票数 0
回答已采纳
1回答
我正在对两个不同的项目进行压力测试:一个是用C编写的proxsmtpd - smtp proxy，另一个是smtp_proxy.py，它是我在1小时内使用asyncore和smtpd python模块开发的。
我在繁重的负载下对这两个项目进行了测试，发现proxsmtpd能够保持400smtp会话/秒，而我的python程序只能处理160smtp会话/sec。
所以，我的问题是，这是因为asyncore存在一些性能限制，还是C程序只是速度更快？或者可能是我，以一种低效的方式使用asyncore？
浏览 3提问于2010-01-08得票数 2
回答已采纳
我将ARM Cortex-A9 processor与Linux Ångström distribution结合使用。我有Python 2.7.3，它是我用Openembedded项目构建的。
我试图在我的系统上使用Supervisord process monitor，但是当我试图运行相同的时候，它会产生以下错误：
root@myDevice:~#监督跟踪(最近一次调用)：文件“/usr/lib/python2.7/sychat.py”，第52行，在ImportError中没有名为异步核心的模块
我知道我安装的python包可能是不完整的，我需要安装软件包来解决这个问题。我有opkg
浏览 0提问于2015-09-01得票数 2
回答已采纳
3回答
我如何才能让一个正在运行的套接字服务器接受传入的连接并处理该部分代码，同时又不让代码在同一循环中等待新的连接？
我才刚刚开始尝试学习。TCP处理程序有用吗？
我只需要关于这个主题的一些简单的例子。我想要一些东西，比如在服务器中有一个命令部分。因此，我可以在服务器运行时执行某些操作。
编辑:我想要做的是：
1 - TCP server for multiple clients
2 - Respond to more than one at a time when needed
3 - Text input availability at all time, to be used for gett
浏览 0提问于2011-09-15得票数 2
回答已采纳
我想编写一个客户端可以连接并接收定期更新的服务器，而不需要轮询。我在使用asyncore时遇到的问题是，如果在调用dispatcher.writable()时没有返回true，则必须等到asyncore.loop超时之后(默认为30s)。
我试图解决这个问题的两种方法是: 1)将超时时间减少到一个较低的值；2)查询连接的下次更新时间并生成足够的超时值。但是，如果您在‘man2select_tut’中引用'Select Law‘，它会声明，“您应该始终尝试使用select()而不超时。”
有没有更好的方法来做这件事？也许是扭曲的？我想试着避免额外的线程。我将在这里包含变量超时示例：
#!
浏览 1提问于2009-06-24得票数 8
回答已采纳
我想设置SMTP中继服务器，它也需要使用HTTP代理。我使用的是Python。
SMTP代理：
import smtpd
import asyncore
smtpd.PureProxy(('local host name', 1234), ('smtp server name', 25))
asyncore.loop()
问题是我需要使用HTTP代理才能连接到SMTP服务器。
我如何指定它？
浏览 0提问于2011-03-01得票数 0
回答已采纳
1回答
我正在将一些ActionScript代码移植到Python上，并且正在为类似于flash.events.EventDispatcher中可用的某种事件分派器实现而奋斗。
我需要创建一个客户端套接字连接到服务器，这将响应一个横幅。然后客户端将发送一些信息，接收一个新的横幅等。
我知道如何创建客户端套接字，但问题是如何处理事件，以便客户端根据事件运行适当的函数。
我读过一些关于各种模块的文章，比如Asyncore和Twisted，老实说，我正在寻找一些快速且易于实现的东西。我需要将代码移植到最小的范围内，作为概念的证明。
这里的是我使用异步核心的代码的一部分：
import socket
impo
浏览 1提问于2011-02-03得票数 1
在这一点上，当涉及到GUI和网络编程时，我仍然是一个新手，所以我希望这将是一个非常简单的解决方案。我已经对tkinter和asyncore模块有了一个非常基本的了解，在每个模块中都构建了一些程序，但是我在一个程序中同时使用这两个模块时遇到了问题。我组装了一个完整的UI，结果却发现我无法实现任何重要的异步网络功能。为了简单起见，我将程序解构为最简单的形式，以说明我遇到的基本问题。代码如下：
from Tkinter import *
import asyncore, socket
class Application(object):
def __init__(self, root):
浏览 3提问于2010-01-01得票数 0
我有一个实现asyncore模块的类，它充当连接到HOST_A的客户端。问题是我需要将从HOST_A接收的数据传递到HOST_B。所以我想知道asyncore是否可以创建到HOST_A和HOST_B.Is的两个socket连接？
浏览 3提问于2013-09-06得票数 0
我想使用Python创建一个小型SMTP服务器进行测试，所以我尝试了服务器示例代码
import smtpd
import asyncore
class CustomSMTPServer(smtpd.SMTPServer):
def process_message(self, peer, mailfrom, rcpttos, data):
print 'Receiving message from:', peer
print 'Message addressed from:', mailfrom
print 'Message
浏览 1提问于2020-04-15得票数 1
1回答
我有一个带有asyncore的python上的tcp服务器：
class AsyncClientHandler(asyncore.dispatcher_with_send):
def __init__(self,sock):
asyncore.dispatcher_with_send.__init__(self,sock)
self.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
self.setsockopt(socket.SOL_SOCKET, socket.SO_KEEP
浏览 5提问于2013-06-25得票数 1
我正在尝试使用asyncore dispatcher (下面的代码)通过数据包套接字执行原型式send/recv。尽管我的handle_write方法很快就会被调用，但handle_read方法似乎并没有被调用。loop()确实经常调用readable方法，但是我不能接收任何东西。我知道在eth0上接收到了数据包，因为简单的tcpdump会显示传入的数据包。我是不是遗漏了什么？
#!/usr/bin/python
import asyncore, socket, IN, struct
class packet_socket(asyncore.dispatcher):
def __
浏览 1提问于2009-04-06得票数 1
回答已采纳
我一直在尝试制作一个简单的服务器，这样我和我的朋友就可以在上面玩围棋、钓鱼或其他简单的纸牌游戏。我正在学习如何使用asyncore类，我遇到了一个问题。当没有服务器启动时，程序不会连接，但当有服务器启动时，它会说连接成功，但是它从不调用handle_accept方法，即使我去掉了handle_accept方法，它仍然会连接，或者至少不会遇到任何错误。
我一直在使用这个网站和python asyncore方法的描述，但我不知道我做错了什么。
我已经包含了这两个UI的代码以及服务器和客户端代码。
服务器UI
from Tkinter import *
from Server import *
i
浏览 0提问于2012-01-30得票数 0
回答已采纳
我正在编写一个异步核心服务器，它从同一进程中的另一个模块获取信息，并将其写回客户端。信息基本上是一个字典，对于每个键，我们都有一个消息队列。我被要求转储每个队列的长度。代码在测试机器上运行良好，但一旦我将其安装到生产服务器上，我就开始收到以下错误消息："socket.error'>:Errno 32 Broken )“。
这是服务器：
class request_handler (asyncore.dispatcher):
def __init__(self, conn_sock, client_address, dict):
self.c
浏览 2提问于2013-02-07得票数 0
我有一些python脚本，基于asyncore lib，有超过3k的输出套接字连接。我不能使用select(..)由于连接限制(1024)，但轮询(..)不能正常工作：
asyncore.loop(use_poll=True)
使用此调用，我的应用程序会忽略任何套接字事件。请注意，对于少于1024个套接字，select()可以很好地工作。
我的问题在哪里？
浏览 0提问于2011-11-03得票数 1
回答已采纳
2回答
我正在使用python上的asyncore.dispatcher客户端连接到运行在PC上的LabWindows中开发的服务器。下面是连接到服务器的客户机上的代码片段：
class DETClient(asyncore.dispatcher):
def __init__(self, host, port):
asyncore.dispatcher.__init__(self)
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect((host,port))
在服务器端，我的
浏览 9提问于2013-09-13得票数 1
回答已采纳
3回答
从读取asyncore 来看，似乎应该在成功连接到侦听套接字之后调用handle_connect()。但在实践中，asyncore似乎不会运行handle_connect()，除非它在套接字上接收或发送数据包。
举个例子：
我绑定了服务器套接字，并在某个端口上侦听。套接字将接受任何传入的连接，打印接收到的内容，并返回“谢谢”。
然后，我启动了一个基于asyncore.dispatcher的客户机，它在创建时连接到服务器套接字。客户端有一个方法handle_connect()，它向服务器发送一个"hello“数据包。它还有一个方法read，用于打印接收到的数据包。(在这种情况下，它应该打
浏览 3提问于2015-06-19得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
