客户端与服务端通过socket进行通信。

服务端:

import socket
import threading

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
#监听0.0.0.0这个特殊的ip,就可以监听本机上所有的ip地址
sock.bind(('0.0.0.0', 10086))
sock.listen(5)#限制最多同时连接的客户端数量为5


def echo_server(client: socket.socket, address: tuple):
    print('来自{}:{}的客户端已连接'.format(address[0], address[1]))
    client.send('欢迎来自{}:{}的新客户端\r\n'.format(address[0], address[1]).encode('utf-8'))
    while True:
        content = client.recv(1024)
        if content == b'exit':
            break
        elif content:
            print(content.decode('utf-8'))
        else:
            break
    print('来自{}:{}的客户端已退出'.format(address[0], address[1]))
    client.close()

print('Server start! Listening 0.0.0.0:10086')
while True:
    client, address = sock.accept()
    t = threading.Thread(target=echo_server, args=(client, address))
    t.start()

客户端

import socket


client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('127.0.0.1', 10086))
client.send("I'm Client!".encode('utf-8'))

server_content = client.recv(1024)
print(server_content.decode('utf-8'))
client.send(b'exit')
client.close()

当客户端连接的时候,服务端输出:

Server start! Listening 0.0.0.0:10086
来自127.0.0.1:64219的客户端已连接
I'm Client!
来自127.0.0.1:64219的客户端已退出

客户端:

欢迎来自127.0.0.1:64219的新客户端

你也可能喜欢

发表评论

您的电子邮箱地址不会被公开。 必填项已用*标注