Linux开发板(树莓派)和服务器进行双向通信(socket)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
import socket
import sys


def socket_service_data():
    # 连接
    try:
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        s.bind(ADDR)  # 在不同主机或者同一主机的不同系统下使用实际ip
        s.listen(10)
    except socket.error as msg:
        print(msg)
        sys.exit(1)
    print("Wait for Connection..................")
	sock, addr = s.accept()
    
    while True:
        # 收
        buf = sock.recv(BUFSIZ)  # 接收数据
        buf1 = buf.decode('utf-8')  # 解码
        if not buf:
            break
        print('Received message:', buf1)
        # return buf
        # 发
        buf = input("input data:")  # 输入要传输的数据
        if not buf:
            break
        sock.send(buf.encode())  # 将要传输的数据编码发送，如果是字符数据就必须要编码发送
    # 关闭socket
    sock.close()


if __name__ == '__main__':
    # 初始化
    name = socket.gethostname()
    HOST = socket.gethostbyname(name)  # 获取阿里云服务器私网IP，使用ifconfig可查询
    PORT = 7000
    BUFSIZ = 1024
    ADDR = (HOST, PORT)

    socket_service_data()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
import socket
import sys


def sock_client_data():
    # 连接
    try:
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.connect(ADDR)
    except socket.error as msg:
        print(msg)
        print(sys.exit(1))

    while True:
        # 发
        data = input("input data:")  # 输入要传输的数据
        if not data:
            break
        s.send(data.encode('utf-8'))  # 将要传输的数据编码发送，如果是字符数据就必须要编码发送
        # 收
        data = s.recv(BUFSIZ)
        if not data:
            break
        print(data.decode('utf-8'))
    # 关闭socket
    s.close()


if __name__ == '__main__':
    # 初始化
    HOST = '99.100.101.102'  # 比如 99.100.101.102是你的服务器的公网IP
    PORT = 7000  # IP开放的socket端口
    BUFSIZ = 1024
    ADDR = (HOST, PORT)

    sock_client_data()