Python使用TCP通讯例子

TCP通讯十分常用,对应Python库为socket

import json
import socket 

tcp_server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

tcp_server.setsockopt(socket.SOL_SOCKET,socket.SO_SNDBUF,65536)
tcp_server.setsockopt(socket.SOL_SOCKET,socket.SO_RCVBUF,65536)
print(f'Send Buf: {tcp_server.getsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF)}') 
print(f'Recv Buf: {tcp_server.getsockopt(socket.SOL_SOCKET, socket.SO_RCVBUF)}') 

tcp_server.bind(('127.0.0.1', 2022))
tcp_server.listen(128)

print(f'Server IP: {tcp_server.getsockname()}')

while True:
    client_socket, client_addr = tcp_server.accept()
    data = client_socket.recv(1024)
    print(f'Request: {data.decode()}')
    data = json.loads(data)
    data['status'] = 'ok'
    data = json.dumps(data)
    client_socket.send(data.encode())

上段为TCP服务端,下段为TCP客户端,如果只需要单次连接的话去掉循环就好;

import time
import json
import socket

while True:
	server_addr = ('127.0.0.1', 2022) 
	tcp_client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
	tcp_client.settimeout(5)
	tcp_client.connect(server_addr)
	data = json.dumps({'message':'status'})

	tcp_client.send(data.encode())
	data = tcp_client.recv(1024)
	print(f'Respond: {data.decode()}')    
	tcp_client.close()
	time.sleep(1)
### Python TCP Socket 非阻塞通信实例 对于非阻塞性的套接字操作,在创建套接字之后,可以通过调用 `setblocking(False)` 方法来改变默认的行为[^2]。 ```python import socket def main(): # 创建一个非阻塞模式下的客户端套接字对象 client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client_socket.setblocking(False) try: # 尝试连接到服务器;如果立即无法建立连接,则抛出异常 client_socket.connect_ex(('localhost', 8080)) message = "Hello from non-blocking client!" sent_data_length = 0 while sent_data_length < len(message): bytes_sent = client_socket.send(message[sent_data_length:].encode('utf-8')) if bytes_sent == 0: break # 如果发送失败则退出循环 sent_data_length += bytes_sent received_message_parts = [] while True: try: part = client_socket.recv(1024).decode('utf-8') if not part: break received_message_parts.append(part) except BlockingIOError: continue # 当没有更多数据可读取时继续等待 full_received_message = ''.join(received_message_parts) print(f"Received data: {full_received_message}") finally: client_socket.close() if __name__ == "__main__": main() ``` 在这个例子中,通过设置 `client_socket` 的阻塞标志位为假(`False`)实现了非阻塞行为。当尝试向服务器发送消息或接收来自服务器的消息而这些动作暂时不可完成时(比如因为网络延迟),程序不会被卡住而是会遇到 `BlockingIOError` 异常并处理它——这里简单地选择了忽略错误并重试直到成功为止或者确定不再有新数据到来。
评论
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值