python3 多进程实现socket通讯

Posted 2022-01-17 lilyxiaoyy

# -*- coding: utf-8 -*-
import os
from socket import *
from multiprocessing import Process


def talk(conn):
    while 1:  # 循环通讯
        try:
            from_client_msg = conn.recv(1024)
            if not from_client_msg:break
            print("进程<%s>来自客户端的消息:%s" %(os.getpid(), from_client_msg))
            conn.send(from_client_msg.upper())
        except:
            break
    conn.close()


if __name__ == ‘__main__‘:
    ‘‘‘一个进程里开多线程实现socket通讯‘‘‘
    server = socket()
    ip_port = ("127.0.0.1", 8001)
    server.bind(ip_port)
    server.listen(5)
    while 1:  # 循环连接
        conn, addr = server.accept()
        p = Process(target=talk, args=(conn,))
        p.start()
    server.close()
    
# 进程<7412>来自客户端的消息:b‘aaa‘
# 进程<6972>来自客户端的消息:b‘bbb‘
# 进程<2132>来自客户端的消息:b‘vvv‘
# 进程<7492>来自客户端的消息:b‘eee‘
# 进程<3660>来自客户端的消息:b‘xxx‘
# 进程<1940>来自客户端的消息:b‘zzz‘

# -*- coding: utf-8 -*-
from socket import *


client = socket()
ip_port = ("127.0.0.1", 8001)
client.connect(ip_port)
while 1:  # 循环通讯
    inp = input(">>:").strip()
    if not inp: continue
    if inp.upper() == "Q": break
    client.send(inp.encode())
    from_server_msg = client.recv(1024)
    print("来自服务端的消息:", from_server_msg)
client.close()