python多线程、多进程处理Socket并发服务端、客户端案例

服务端：多线程处理Socket并发

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2018/10/13 21:56
# @Author  : DoubleChina
# @Site    : 
# @File    : ThreadSocket.py
# @Software: PyCharm
import socket
import threading

server = socket.socket()
server.bind(('', 9999))
server.listen(5)


def readThread(conn, addr):
    """
    创建一个新的线程，负责和一个客户端通讯
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客户端{}已关闭".format(addr))
            break
    conn.close()


while True:
    print('------主线程，等待客户端连接------')
    conn, addr = server.accept()
    print('创建一个新的线程，和客户端{}通讯'.format(addr))
    # 创建一个子线程，负责消息收发
    client = threading.Thread(target=readThread, args=(conn, addr))
    # 启动线程
    client.start()

服务端：多进程处理Socket并发

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2018/10/13 21:56
# @Author  : DoubleChina
# @Site    : 
# @File    : ThreadSocket.py
# @Software: PyCharm
import socket
import threading
import multiprocessing

server = socket.socket()
server.bind(('', 9999))
server.listen(5)


def readProcess(conn, addr):
    """
    创建一个新的线程，负责和一个客户端通讯
    :param conn:
    :param addr:
    :return:
    """
    while True:
        data = conn.recv(1024)
        if data:
            print('{}:{}'.format(addr, data))
        else:
            print("客户端{}已关闭".format(addr))
            break
    conn.close()


while True:
    print('------主线程，等待客户端连接------')
    conn, addr = server.accept()
    print('创建一个新的进程，和客户端{}通讯'.format(addr))
    # 创建一个子进程
    p = multiprocessing.Process(target=readProcess, args=(conn, addr))
    p.start()

socket连接客户端

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2018/10/13 7:38
# @Author  : DoubleChina
# @Site    :
# @File    : SocketTest.py
# @Software: PyCharm
import socket

# 创建套接字
s = socket.socket()
# 连接套接字，ip和端口必须是服务器上的
s.connect(('127.0.0.1', 9999))
while True:
    data = input("输入发送消息:")
    if 'q' == data:
        s.close()
        break
    s.send(data.encode())
    # print('接受服务器返回的消息：', s.recv(1024))
# s.close()