Python基于Socket实现简易即时通讯:客户端与服务器代码详解
本文通过Python标准库socket模块,演示如何构建一个基于TCP协议的简易即时通讯系统。文章分别提供了客户端tcpclient.py和服务器端tcpserver.py的完整代码示例,利用threading模块实现收发数据的多线程处理,帮助开发者快速理解网络通信的基本原理与代码结构。
本文通过Python标准库socket模块,演示如何构建一个基于TCP协议的简易即时通讯系统。文章分别提供了客户端tcpclient.py和服务器端tcpserver.py的完整代码示例,利用threading模块实现收发数据的多线程处理,帮助开发者快速理解网络通信的基本原理与代码结构。
客户端实现文件命名为tcpclient.py,负责发起连接并处理用户输入与服务器响应的交互逻辑。
# -*- coding: utf-8 -*-
import socket
import threading
# 目标地址IP/URL及端口
target_host = "127.0.0.1"
target_port = 9999
# 创建一个socket对象
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 连接主机
client.connect((target_host,target_port))
def handle_send():
while True:
content = raw_input()
client.send(content)
def handle_receive():
while True:
response = client.recv(4096)
print response
send_handler = threading.Thread(target=handle_send,args=())
send_handler.start()
receive_handler = threading.Thread(target=handle_receive,args=())
receive_handler.start()
服务器端实现文件命名为tcpserver.py,负责监听指定端口、接受客户端连接并处理双向通信。
# -*- coding: utf-8 -*-
import socket
import threading
# 监听的IP及端口
bind_ip = "127.0.0.1"
bind_port = 9999
#socket 服务器初始化
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind((bind_ip,bind_port))
server.listen(5)
print "[*] Listening on %s:%d" % (bind_ip,bind_port)
# 定义函数handle_client,输入参数client_socket
def handle_client():
while True:
request = client_socket.recv(1024)
print "[*] Received:%s" % request
def handle_send():
while True:
content = raw_input()
client_socket.send(content);
#阻塞在这里,等待接收客户端的数据
client_socket,addr = server.accept()
print "[*] Accept connection from:%s:%d" % (addr[0],addr[1])
#创建一个线程
client_handler = threading.Thread(target=handle_client,args=())
client_handler.start()
send_handler = threading.Thread(target=handle_send,args=())
send_handler.start()
更多关于Python相关内容可查看本站专题:《Python Socket编程技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》及《Python文件与目录操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
免责声明:本文内容仅供参考,不代表本站观点。转载或引用请注明出处。









