MPC (c++) 和 udacity模拟器仿真

sarsa解简易迷宫

  返回  

python这是一个多并发服务器和连接

2021/7/21 1:13:04 浏览:
-------------------------------
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))
            #print('recv:[0],内容:[1]'.format(destAddr,recvData))
            print(f'recv:{destAddr},内容:{recvData}')
        else:
            print('[%s]客户端已经关闭'%str(destAddr))
            #print('[0]客户端已经关闭'.format(destAddr))
            break
    newSocket.close()
def main():
    serSocket = socket(AF_INET, SOCK_STREAM)
    serSocket.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)#设置成可以重复使用的地址
    locaAddr=('',7788)#地址
    serSocket.bind(locaAddr)#b绑定地址
    serSocket.listen(5)#最大连接数
    try:
        while True:
            print('----主进程,等待新客户端的到来------')
            newsocket,dataAddr=serSocket.accept()
            print('主进程,,接下来创建一个新的进程负责数据处理')
            client=Process(target=dealWithClient,args=(newsocket,dataAddr))
            client.start()
            newsocket.close()
    finally:
        serSocket.close()
if __name__ == '__main__':
    main()
-----------------------------
from socket import *

clientSock=socket(AF_INET,SOCK_STREAM)
#连接服务器
clientSock.connect(('169.254.69.137',7788))
    #发送消息

clientSock.send(b'nihao')
#接收消息
#data=clientSock.recv(1024)
#print(data)
clientSock.close()

联系我们

如果您对我们的服务有兴趣,请及时和我们联系!

服务热线:18288888888
座机:18288888888
传真:
邮箱:888888@qq.com
地址:郑州市文化路红专路93号