单进程服务器

1. 完成一个简单的TCP服务器

from socket import *

serSocket = socket(AF_INET, SOCK_STREAM)

# 重复使用绑定的信息

serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR  , 1)

localAddr = ('', 7788)

serSocket.bind(localAddr)

serSocket.listen(5)

while True:

    print('-----主进程，，等待新客户端的到来------')

    newSocket,destAddr = serSocket.accept()

    print('-----主进程，，接下来负责数据处理[%s]-----'%str(destAddr))

    try:

        while True:

            recvData = newSocket.recv(1024)

            if len(recvData)>0:

                print('recv[%s]:%s'%(str(destAddr), recvData))

            else:

                print('[%s]客户端已经关闭'%str(destAddr))

                break

    finally:

        newSocket.close()

serSocket.close()

2. 总结

同一时刻只能为一个客户进行服务，不能同时为多个客户服务
类似于找一个“明星”签字一样，客户需要耐心等待才可以获取到服务
当服务器为一个客户端服务时，而另外的客户端发起了connect，只要服务器listen的队列有空闲的位置，就会为这个新客户端进行连接，并且客户端可以发送数据，但当服务器为这个新客户端服务时，可能一次性把所有数据接收完毕
当recv接收数据时，返回值为空，即没有返回数据，那么意味着客户端已经调用了close关闭了；因此服务器通过判断recv接收数据是否为空来判断客户端是否已经下线

多进程服务器

1. 多进程服务器

from socket import *

from multiprocessing import *

from time import sleep

# 处理客户端的请求并为其服务

def dealWithClient(newSocket,destAddr):

    while True:

        recvData = newSocket.recv(1024)

        if len(recvData)>0:

            print('recv[%s]:%s'%(str(destAddr), recvData))

        else:

            print('[%s]客户端已经关闭'%str(destAddr))

            break

    newSocket.close()

def main():

    serSocket = socket(AF_INET, SOCK_STREAM)

    serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR  , 1)

    localAddr = ('', 7788)

    serSocket.bind(localAddr)

    serSocket.listen(5)

    try:

        while True:

            print('-----主进程，，等待新客户端的到来------')

            newSocket,destAddr = serSocket.accept()

            print('-----主进程，，接下来创建一个新的进程负责数据处理[%s]-----'%str(destAddr))

            client = Process(target=dealWithClient, args=(newSocket,destAddr))

            client.start()

            #因为已经向子进程中copy了一份（引用），并且父进程中这个套接字也没有用处了

            #所以关闭

            newSocket.close()

    finally:

        #当为所有的客户端服务完之后再进行关闭，表示不再接收新的客户端的链接

        serSocket.close()

if __name__ == '__main__':

    main()

2. 总结

通过为每个客户端创建一个进程的方式，能够同时为多个客户端进行服务
当客户端不是特别多的时候，这种方式还行，如果有几百上千个，就不可取了，因为每次创建进程等过程需要好较大的资源

多线程服务器

#coding=utf-8

from socket import *

from threading import Thread

from time import sleep

# 处理客户端的请求并执行事情

def dealWithClient(newSocket,destAddr):

    while True:

        recvData = newSocket.recv(1024)

        if len(recvData)>0:

            print('recv[%s]:%s'%(str(destAddr), recvData))

        else:

            print('[%s]客户端已经关闭'%str(destAddr))

            break

    newSocket.close()

def main():

    serSocket = socket(AF_INET, SOCK_STREAM)

    serSocket.setsockopt(SOL_SOCKET, SO_REUSEADDR  , 1)

    localAddr = ('', 7788)

    serSocket.bind(localAddr)

    serSocket.listen(5)

    try:

        while True:

            print('-----主进程，，等待新客户端的到来------')

            newSocket,destAddr = serSocket.accept()

            print('-----主进程，，接下来创建一个新的进程负责数据处理[%s]-----'%str(destAddr))

            client = Thread(target=dealWithClient, args=(newSocket,destAddr))

            client.start()

            #因为线程中共享这个套接字，如果关闭了会导致这个套接字不可用，

            #但是此时在线程中这个套接字可能还在收数据，因此不能关闭

            #newSocket.close()

    finally:

        serSocket.close()

if __name__ == '__main__':

    main()

巴特西

python网络编程（八）

单进程服务器

1. 完成一个简单的TCP服务器

2. 总结

多进程服务器

1. 多进程服务器

2. 总结

多线程服务器

最新文章

热门文章