socket通信

socket通信的伪代码流程：

 

socket简单的示例代码

client端的代码：

import socket

client = socket.socket()
client.connect(('localhost',3001))

client.send(b'hhhh')
data = client.recv(1024)
print('recv:',data)

client.close()

客户端结果
>>> recv: b'HHHH'

server端的代码：

import socket

server = socket.socket()

server.bind(('localhost',3001)) #绑定要监听端口
server.listen()                 #监听

print('开始等待数据....')

#conn表示客户端连接到服务端生成的一个连接实例
conn,addr = server.accept() #等待数据

print(conn,addr)


print('数据来了')
data = conn.recv(1024)
print('recv:',data)

conn.send(data.upper())

server.close()

服务端结果
>>> 开始等待数据....
>>> <socket.socket fd=296, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 3001), raddr=('127.0.0.1', 54373)> ('127.0.0.1', 54373)
>>> 数据来了
>>> recv: b'hhhh'

 socket多用户连接：

client端的代码：

import socket
import os

client = socket.socket()
client.connect(('localhost', 3001))
while True:
    #让用户自己输入要发送的信息msg，因为涉及到中文，所已用encode和decode进行转换
    msg = input(">>>:").strip()
    if len(msg) == 0:
        continue
    client.send(msg.encode("utf-8"))
    data = client.recv(1024)
    print('recv:', data.decode())

client.close()

server端的代码：

import socket
import os

server = socket.socket()  # 创建套接字
server.bind(('localhost', 3001))  # 绑定要监听端口
server.listen(1)  # 监听,数据代表允许多少个链接

print('开始等待数据....')
# conn表示客户端连接到服务端生成的一个连接实例
# 先说第二个while，循环接收客户端数据，当客户端数据没有发送，服务端收到数据为空的时候跳出循环，这么做是因为这个程序如果想要一直接收客户端数据，就需要进行循环操作，但是如果收到数据为空，该循环就会进入一个死循环，所以需要判定条件，当客户端结束发送数据，然后结束连接;
# 然后第一个while，因为这里考虑测试多人单线程连接server，如果不加while，当客户端数据没有发送，server会直接断开连接，不接收下个新用户的请求数据，所以将一个连接实例放在循环里，当一个用户断开连接，回到上层，然后再接收新用户的数据。
while True:
    conn, addr = server.accept()  # 等待数据
    print(conn, addr)
    print('数据来了')
    while True:
        data = conn.recv(1024)
        print('recv:', data)
        if not data:
            print('The client did not respond')
            break
         conn.send(data.upper())

server.close()

socket简单的shell实现：

client端的代码：

import socket
import os

client = socket.socket()
client.connect(('localhost', 3001))
while True:
    #让用户自己输入要发送的信息msg，因为涉及到中文，所已用encode和decode进行转换
    msg = input(">>>:").strip()
    if len(msg) == 0:
        continue
    client.send(msg.encode("utf-8"))
    data = client.recv(1024)
    #print('recv:', data.decode())
    print(data.decode())

client.close()

server端的代码：

import socket
import os

server = socket.socket()  # 创建套接字
server.bind(('localhost', 3001))  # 绑定要监听端口
server.listen(1)  # 监听,数据代表允许多少个链接

print('开始等待数据....')
while True:
    conn, addr = server.accept()  # 等待数据
    print(conn, addr)
    print('数据来了')
    while True:
        data = conn.recv(1024)
        print('recv:', data)
        if not data:
            print('The client did not respond')
            break
        res = os.popen(data.decode()).read()  #py3 里socket发送的只有bytes,os.popen又只能接受str,所以要decode一下
        conn.send(res.encode("utf-8"))

server.close()