Python – 如何让客户端能够连接多次？

概述当我使用client1 = HTTPClient(‘192.168.1.2′,’3’)时,它只能工作,但当我使用如下两者时： client1 = HTTPClient(‘192.168.1.2′,’3’) client2 = HTTPClient(‘192.168.1.3′,’3’) 然后整个事情变得非常缓慢,有时其中一个失败.如何确保client1和client2连接发送速度足够快？ impor 当我使用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,socketclass httpClIEnt(asyncore.dispatcher):  def __init__(self,host,path):    asyncore.dispatcher.__init__(self)    self.create_socket(socket.AF_INET,socket.soCK_STREAM)    self.settimeout(10)    try:      self.connect( (host,8888) )    except:      print 'unable to connect'      pass    self.buffer = path  def handle_connect(self):    pass  def handle_close(self):    self.close()  def handle_read(self):    print self.recv(8192)  def writable(self):    return (len(self.buffer) > 0)  def handle_write(self):    sent = self.send(self.buffer)    self.buffer = self.buffer[sent:]clIEnt1 = httpClIEnt('192.168.1.2','3')clIEnt2 = httpClIEnt('192.168.1.3','3')asyncore.loop()

编辑：尝试也线程但相同的结果

import asyncore,socketimport threadingimport osclass httpClIEnt(asyncore.dispatcher):  def __init__(self,8888) )    except:      print 'unable to connect'      pass    self.buffer = path  def handle_connect(self):    pass  def handle_close(self):    self.close()  def handle_read(self):    print self.recv(8192)  def writable(self):    return (len(self.buffer) > 0)  def handle_write(self):    sent = self.send(self.buffer)    self.buffer = self.buffer[sent:]def t1():  clIEnt1 = httpClIEnt('192.168.1.161','3')  def t2():  clIEnt2 = httpClIEnt('192.168.1.163','3')t0 = threading.Thread(target=t1())t0.start()t0.join() t0 = threading.Thread(target=t2())t0.start()t0.join() asyncore.loop()

解决方法 您的代码中可能存在多个问题,例如,在指定目标时删除括号：Thread(target = t1).如果f是函数,则f()立即调用它.您还将asyncore与阻塞代码和多个线程混合使用.

如果你想同时建立几个http连接;您可以使用线程池：

import urllib2from multiprocessing.dummy import Pool # use threadsdef fetch(url):    try:        return url,urllib2.urlopen(url).read(),None    except Exception as e:        return url,None,str(e)urls = ['http://example.com',...]pool = Pool(20) # use no more than 20 concurrent connectionsfor url,result,error in pool.imap_unordered(fetch,urls):    if error is None:       print(url + " done")    else:       print(url + " error: " + error)

总结

以上是内存溢出为你收集整理的Python – 如何让客户端能够连接多次？全部内容，希望文章能够帮你解决Python – 如何让客户端能够连接多次？所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。