【Python】网络编程

Socket

Socket (简称 套接字)是进程之间通信一个工具，进程之间想要进行网络通信需要socket。Socket负责进程之间的网络数据传输，好比数据的搬运工。

客户端和服务端

2个进程之间通过Socket进行相互通讯，就必须有服务端和客户端

Socket服务端：等待其它进程的连接、可接受发来的消息、可以回复消息

Socket客户端：主动连接服务端、可以发送消息、可以接收回复

Socket服务端编程

主要分为如下几个步骤：
1、创建socket对象

import socket
socket_server = socket.socket()

2、绑定socket_server到指定IP和地址

socket_server.bind((host, port))

3、服务端开始监听端口

socket_server.listen(backlog)
# backlog为int整数，表示允许的连接数量，超出的会等待，可以不填，不填会自动设置一个合理值

4、接收客户端连接，获得连接对象

conn, address = socket_server.accept()
print(f'接收到客户端连接，连接来自：{address}')
# accept()是阻塞方法，如果没有连接，会卡在当前这一行不向下执行代码
# accept()返回的是一个二元元组，可以使用上述形式，用两个变量接收二元元组的2个元素

5、客户端连接后，通过recv方法，接收客户端发送的消息

while True:
    data = conn.recv(1024).decode('UTF-8')
    # recv()的返回值是字节数组（Bytes），可以通过decode使用UTF-8解码为字符串
    # recv()的传参是buffsize（缓冲区大小），一般设置为1024即可
    print(f'接收到发送来的数据：{data}')

    # 6、通过conn（客户端当次连接对象），调用send()可以回复消息
    reply = input('输入要和客户端回复的消息：')
    if reply == 'exit':
        break
    conn.send(reply.encode('UTF-8'))
# 可以通过while True无线循环来持续和客户端进行数据交互
# 可以通过判定客户端发来的特殊标记，如exit，来退出无线循环

服务器托管网

7、conn（客户端当次连接对象）和socket_server对象调用close()关闭连接

示例：

# socket服务端开发
import socket

# 1、创建socket对象
socket_server = socket.socket()

# 2、绑定socket_server到指定IP和地址
socket_server.bind(('localhost', 8888))

# 3、服务端开始监听端口
socket_server.listen(1)

# 4、接收客户端连接，获得连接对象
conn, address = socket_server.accept()
print(f'接收到客户端连接，连接来自：{address}')

# 5、客户端连接后，通过recv方法，接收客户端发送的消息
while True:
    data = conn.recv(1024).decode('UTF-8')
    # recv()的返回值是字节数组（Bytes），可以通过decode使用UTF-8解码为字符串
    # recv()的传参是buffsize（缓冲区大小），一般设置为1024即可
    print(f'接收到发送来的数据：{data}')

    # 6、通过conn（客户端当次连接对象），调用send()可以回复消息
    reply = input('输入要和客户端回复的消息：')
    if reply == 'exit':
        br服务器托管网eak
    conn.send(reply.encode('UTF-8'))

# 7、关闭连接
conn.close()
socket_server.close()

Socket客户端编程

主要分为如下几个步骤：

1、创建socket对象

import socket
socket_server = socket.socket()

2、连接到服务端

socket_client.connect((host, port))

3、发送消息

while True:
    send_msg = input('输入要发送的消息：')
    if send_msg == 'exit':
        # 通过特殊标记来确保可以退出无线循环
        break
    socket_client.send(send_msg.encode('UTF-8'))	# 消息需要编码为字节数组（UTF-8编码）
    
    # 4、接收返回消息
    recv_data = socket_client.recv(1024).decode('UTF-8')	# 接收到的消息需要通过UTF-8解码为字符串
    # 1024是缓冲区大小，一般1024即可
    # recv()是阻塞式的，即不接收到返回，就卡在这里等待
    print(f'服务端回复消息为：{recv_data}')	

4、关闭连接

socket_client.close()

示例：

# socket客户端开发
import socket

# 1、创建socket对象
socket_client = socket.socket()

# 2、连接到服务端
socket_client.connect(('localhost', 8888))

# 3、发送消息
while True:
    send_msg = input('输入要发送的消息：')
    if send_msg == 'exit':
        # 通过特殊标记来确保可以退出无线循环
        break
    socket_client.send(send_msg.encode('UTF-8'))  # 消息需要编码为字节数组（UTF-8编码）

    # 4、接收返回消息
    recv_data = socket_client.recv(1024).decode(
        'UTF-8')    # 接收到的消息需要通过UTF-8解码为字符串
    # 1024是缓冲区大小，一般1024即可
    # recv()是阻塞式的，即不接收到返回，就卡在这里等待
    print(f'服务端回复消息为：{recv_data}')

# 4、关闭连接
socket_client.close()

运行结果

先运行服务端，再运行客户端。此处启动两个cmd窗口进行演示。

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: 可观测性数据收集集大成者 Vector 介绍

如果企业提供 IT 在线服务，那么可观测性能力是必不可少的。“可观测性” 这个词近来也越发火爆，不懂 “可观测性” 都不好意思出门了。但是可观测性能力的构建却着实不易，每个企业都会用到一堆技术栈来组装建设。比如数据收集，可能来自某个 exporter，可能来自…