Python-сообщество

#!/usr/bin/python
import socket,time,threading
HOST = 'localhost'
PORT = 5000
class OnConnect(threading.Thread):
    def __init__(self,conn,addr,indexx):
        threading.Thread.__init__(self)
        self.conn=conn
        self.addr=addr
        self.indexx=indexx
        self.start()
    def run(self):
        while 1:
            try: data = self.conn.recv(1024)
            except:
                break
            else:
                if (not data) : break
                self.conn.send(data)
            time.sleep(0.1)
        self.conn.close()
        print  self.indexx,'-',self.addr[0],':',self.addr[1],'(',time.asctime(time.gmtime(time.time())),')'

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
print 'Run in',time.asctime(time.gmtime(time.time()))
print 'Host: ',HOST
print 'port: ',PORT
s.listen(1)
d=0
threading.stack_size(0x100000)
while 1:
    conn, addr = s.accept()
    d=d+1
    print d,'+',addr[0],':',addr[1],'(',time.asctime(time.gmtime(time.time())),')'
    OnConnect(conn,addr,d)
    time.sleep(0.1)
conn.close()

import socket,threading,time
class TestServ(threading.Thread):
    def __init__(self,s):
        threading.Thread.__init__(self)
        self.s=s
        self.start()
    def run(self):
        for i in range(1000):
            self.s.send('x')
            data=self.s.recv(1024)
            time.sleep(1)
        self.s.send('exit')
        self.s.close()
port=5000
threading.stack_size(0x100000)
for i in range(10000):
    print i
    s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    s.connect(('localhost',port))
    TestServ(s)
    time.sleep(0.1)

Traceback (most recent call last):
  File "./server.py", line 55, in <module>
    thread.start()
  File "/usr/lib/python2.6/threading.py", line 474, in start
    _start_new_thread(self.__bootstrap, ())
thread.error: can't start new thread

import eventlet
eventlet.monkey_patch()

import sys
from threading import Thread
import socket

HOST, PORT = 'localhost', 5000

def handle(index, addr, conn):
    while True:
        data = conn.recv(1024)
        if not data:
           break
        conn.send(data)
    print 'client %i disconnected' % index

if __name__ == '__main__':

    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.bind((HOST, PORT))
    sock.listen(1)

    print 'Server is waiting for connections on %s:%d' % (HOST, PORT)

    index = 0
    while True:
        index += 1
        conn, addr = sock.accept()
        print "client connected from %s:%s. Creating thread %d" % (addr[0], addr[1], index)
        thread = Thread(target=handle, args=(index, addr, conn))
        thread.start()