zoukankan      html  css  js  c++  java
  • socket如果一个连接被占用,其他连接发回超时

    node1:/root/test#cat t200.py 
    # coding = utf-8
    # -*- coding:utf-8 -*-
    import socket
    import time
    ip_port = ('192.168.137.2',8080)
    BUFSIZE = 9000
    SEND_BUF_SIZE =  2
    RECV_BUF_SIZE = 1
    s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)#创建套接字
    print("Buffer size [Before]: %d" % s.getsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF))
    print("Buffer size [Before]: %d" % s.getsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF))
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.setsockopt( socket.SOL_SOCKET, socket.SO_SNDBUF, SEND_BUF_SIZE)
    s.setsockopt( socket.SOL_SOCKET, socket.SO_RCVBUF, RECV_BUF_SIZE)
    print 'alter----------------';
    print s.getsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF)
    print s.getsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF)
    #s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 0)
    s.bind(ip_port)#绑定地址
    s.listen(5)#监听链接
    print('server listening8080...')
    while True: #无限等待连接
        conn,addr = s.accept() #接受客户端连接
        print(conn)
        print(addr)
        print('接到来自%s的链接'%addr[0])
        while True: #通信循环,无限接受客户端信息
            #print conn.getpeername()
            msg = conn.recv(BUFSIZE) #接受消息的内容
            print 'xxx--------------------xxx'
            print msg
            if len(msg)==0:break  #如果 不加,已连接的客户端突然断开,recv不再阻塞,发生死循环
            print 'xxx--------------------xxx'
            time.sleep(100)
            conn.send('response:'+str(len(msg)))
            #conn.send(msg.upper())#服务端发送消息
        conn.close()#关闭链接
    s.close()#关闭套接字
    node1:/root/test#
    
    
    node1:/root/test#python t200.py 
    Buffer size [Before]: 16384
    Buffer size [Before]: 87380
    alter----------------
    2048
    2280
    server listening8080...
    <socket._socketobject object at 0x7fc9b27577c0>
    ('192.168.137.3', 28660)
    接到来自192.168.137.3的链接
    xxx--------------------xxx
    aaaaaaaaaaaaaaa
    xxx--------------------xxx
    
    
    node2:/root/test#python connect1.py 
    
    node2:/root/test#time python connect2.py 
    Traceback (most recent call last):
      File "connect2.py", line 9, in <module>
        print s.recv(90)
    socket.timeout: timed out
    
    real	0m10.065s
    user	0m0.039s
    sys	0m0.012s
    node2:/root/test#
    
    如果一个连接已经被占用,再启用其他会话去发 会等待超时
  • 相关阅读:
    cms模板内的标签替换思路(不可能比这更优秀的了)
    Mysql数据不算大,备份却非常慢
    PHP防止盗链
    Flash+PHP多文件上传,可将PHP换成别的语言脚本,如asp;jsp等
    把Linux Ubuntu安装到U盘上
    PHP中功能强大却少使用的函数 为你提供更多的思路
    云端計算詳解
    PHP循环输出变量
    HipHop
    80后传记
  • 原文地址:https://www.cnblogs.com/hzcya1995/p/13348284.html
Copyright © 2011-2022 走看看