优秀的编程知识分享平台

网站首页 > 技术文章 正文

Python网络编程的TCP客户端和服务器端交互

nanyue 2025-01-01 22:04:38 技术文章 4 ℃

一、python实现单个客户端与云服务器端持续交互

# TCP服务器端--单客户端
from socket import *
from time import ctime
HOST = ''
PORT = 9999
BUFSIZ = 1024
ADDR = (HOST,PORT)
tcpSerSock = socket(AF_INET,SOCK_STREAM)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(5)
while True:
  print('waiting for connecting...')
  tcpClisock, addr = tcpSerSock.accept()
  print('...connected from:',addr)
  while True:
    data = tcpClisock.recv(BUFSIZ)
    if not data:
      break
    #  tcpClisock.send('222'.encode('utf-8'))
    tcpClisock.send(('[%s] %s' % (ctime(), data)).encode())
    print(ctime(), data)
  tcpClisock.close()
tcpSerSock.close()


1、通过TCP客户端发包工具,实现TCP客户端编程在云服务器上的验证



二、python实现多个客户端与云服务器端持续交互

1、通过TCP客户端发包工具,实现TCP客户端和服务器端在云服务器上的数据交互

# 导入socket和threading
import socket
import threading


# 定义handle_client_request 循环以保持与客户端的连接,并能持续互相传递消息
def handle_client_request(service_client_socket, ip_port):
	while True:
		# 5 接收数据,最大接收为1024字符 
		recv_data = service_client_socket.recv(1024)
		if recv_data:
			print(recv_data.decode('utf-8'), ip_port)  # 将二进制格式转换为'utf-8'
		# 6 服务器返回数据
			back = f'自动回复:欢迎,您发送的数据为:{recv_data.decode("utf-8")}'
			service_client_socket.send(back.encode('utf-8'))  # 将'utf-8'格式转换为二进制
		else:
			print('客户端下线', ip_port)
			break                     


if __name__ == '__main__':
	# 1 创建套接字对象
	tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
	# 设置端口号复用
	tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
	# 2 绑定IP和端口,ip不写或写'127.0.0.1'都是主机本身,此处运行云服务器中不写就是云服务器的IP
	tcp_server_socket.bind(('', 9999))
	# 3 设置监听,一般为5,最大为128
	tcp_server_socket.listen(5)
	while True:
		#  4 接收客户端套接字对象
		service_client_socket, ip_port = tcp_server_socket.accept()
		# 创建线程,传入套接字对象数据
		sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))
		# 守护主线程
		sub_thread.setDaemon(True)
		# 运行线程
		sub_thread.start()

2、通过Pycharm运行tcp客户端测试,在云服务器上的验证tcp服务器端

# TCP客户端
from socket import *
HOST = '1**.***.**.**'
PORT = 9999
BUFSIZ = 1024
ADDR = (HOST, PORT)
tcpClisock = socket(AF_INET,SOCK_STREAM)
tcpClisock.connect(ADDR)
while True:
  data = input('> ')
  if not data:
    break
  tcpClisock.send(data.encode('utf-8'))
  data = tcpClisock.recv(BUFSIZ)
  if not data:
    break
  print(data.decode('utf-8'))

tcpClisock.close()

分别开启3个tcp客户端,发送内容测试,运行在云服务器上的TCP服务器端,均收到了tcp客户端发送的数据;

3、通过手机上的tcp测试软件,模拟tcp客户端测试,在云服务器上的验证tcp服务器端的数据收发情况

Tags:

最近发表
标签列表