} } }

    Python办事器开辟三:Socket

    添加时间:2013-5-23 点击量:

    socket是操纵体系中I/O的延续,它可以使过程和机械之间的通信成为可能。socket可以算作一个标准的文件描述符。不合的是文件须要用open()函数打开,而socket用socket()


    函数建树.recv()、send()函数和read()、write()函数极为类似。


    TCP一般经由过程accept()来为每个连接的客户端建树一个新的scoket。UDP一般只是应用一个单一的socket,完全依附recv()返回的值来断定该往哪里发送响应。



    客户端:


    1、建树一个socket:



    //SOCK_STREAM默示TCP,SOCK_DGRAM默示UDP,AF_INET默示IPv4

    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)


    2、连接socket


    连接socket须要一个tuple参数,来供给IP和端标语:



    s.connect((“www.example.com”, 80))


    3、



    !/usr/bin/env python
    

    import socket

    print Creating socket...
    s
    = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    print done.

    print Looking up port number...
    port
    = socket.getservbyname(httptcp
    print done.

    print Connecting to remote host on port %d... port,
    s.connect((
    www.google.com, port))
    print done.

    获取本身的IP和端标语
    print Connected , s.getsockname()
    获取长途的IP和端标语
    print Connected to, s.getpeername()



    文件类对象:



    import socket, sys
    

    port
    = 70
    host
    = sys.argv[1]
    filename
    = sys.argv[2]

    s
    = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((host, port))
    fd
    = s.makefile(rw, 0)

    fd.write(filename
    + \r\n

    for line in fd.readlines():
    sys.stdout.write(line)


    高等接口:



    import urllib, sys
    

    f
    = urllib.urlopen(sys.argv[1])
    while 1:
    buf
    = f.read(2048
    if not len(buf):
    break
    sys.stdout.write(buf)




    办事器端:


    1、建树一个连接:



    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)


    2、设置socket选项:



    //socket 端口可立即复用
    
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,
    1)


    3、绑定socket:



    s.bind((host, port))


    4、:



    s.listen(1)


    5、接管连接:



    while 1:
    
    clientsock, clientaddr
    = s.accept()
    print Got connection , clientsock.getpeername()
    clientsock.close()


    6、



    !/usr/bin/env python
    

    import socket, traceback

    host
    = Bind to all interfaces
    port = 51423

    s
    = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,
    1
    s.bind((host, port))
    #这里设定每次最多只有一个等待处理惩罚的恳求,真正的办事器会设置一个很高的数字。
    s.listen(
    1

    while 1:
    try:
    clientsock, clientaddr
    = s.accept()
    except KeyboardInterrupt:
    raise
    except:
    traceback.print_exc()
    continue

    Process the connection

    try:
    print Got connection , clientsock.getpeername()
    Process the request here
    except (KeyboardInterrupt, SystemExit):
    raise
    except:
    traceback.print_exc()

    Close the connection

    try:
    clientsock.close()
    except KeyboardInterrupt:
    raise
    except:
    traceback.print_exc()


    应用UDP:



    !/usr/bin/env python
    

    import socket, traceback

    host
    = Bind to all interfaces
    port = 51423

    s
    = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR,
    1
    s.bind((host, port))

    while 1:
    try:
    message, address
    = s.recv(8192
    print Got data , address
    Echo it back
    s.sendto(message, address)
    except (KeyboardInterrupt, SystemExit):
    raise
    except:
    traceback.print_exc()


    我所有的自负皆来自我的自卑,所有的英雄气概都来自于我的软弱。嘴里振振有词是因为心里满是怀疑,深情是因为痛恨自己无情。这世界没有一件事情是虚空而生的,站在光里,背后就会有阴影,这深夜里一片寂静,是因为你还没有听见声音。—— 马良《坦白书》
    分享到: