首页 > 代码库 > python-网络编程-03

python-网络编程-03

2024-09-21 05:43:53   202人阅读

首先我们可以看下可以最简单的交互性的服务端和客户端程序

server

import socket

def main():
    sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    sock.bind((‘localhost‘,8000))
    sock.listen(5)
    while True:
        print ‘1‘
        connection ,clent_addr = sock.accept()
        while 1:
            buf = connection.recv(1024)
            connection.sendall(‘hi‘)
            print buf
    connection.close()
if __name__ == ‘__main__‘:
    main()

[server]：在创建socket之后，服务端会一直保持阻塞状态，然后一旦有用户连接，就立即等待用户发送数据，然后接收到用户发的数据之后 理解返回一个字符后，然后状态变成等待下次连接

client

import socket
sock = socket.socket()
sock.connect((‘localhost‘, 8000))
sock.settimeout(5)
while 1:
    res = sock.recv(1024)
    print res
    data = http://www.mamicode.com/raw_input(‘input:‘)>

[client]：去连接server端然后不断发送数据，然后接受返回。

-------------------------------------------------------------------------------

那么你可以发现上面的server端的代码 其实只能同时接受一个请求，因为只有一个线程去处理这个段代码

那么我可以吧server端的代码换成

import SocketServer

class MyServer(SocketServer.BaseRequestHandler,object):
    def handle(self):
        conn = self.request
        conn.sendall(‘this is a tast‘)
        Flag = True
        while Flag:
            data = http://www.mamicode.com/conn.recv(1024)"data:",data
            if data =http://www.mamicode.com/="exit":
                Flag = True
            elif data =http://www.mamicode.com/= ‘0‘:"The winter in comming")
            else:
                conn.sendall("please input again")

if __name__ == "__main__":
    server01 = SocketServer.ThreadingTCPServer((‘127.0.0.1‘,8080),MyServer)
    print "server is running.."
    server01.serve_forever()

我们通过借助socket自带的类写出来了 多线程的服务器端，能够收发消息

 

python-网络编程-03


联系
我们