您现在的位置是：首页 > 其他

当前栏目

python Socket服务器转发

服务器客户端线程连接数据

2023-03-02 11:23:17 时间

基于多线程  
Server：

import socket
    import threading
    
    #接收数据
    def recive(sock):
        while True:
            try:
                data = sock.recv(1024)
                print("Recive:{}".format(data.decode("utf-8")))
    
                T_trans=threading.Thread(target=broadcast_data,args=(sock, data,))
                T_trans.start()
    
                # sock.send(data)
                # sock.send("From Server:{}".format(data).encode("utf-8"))
            except:
                print(str(addr) + "---offLine！")
                CONNECTION_LIST.remove(sock)
                exit()
    
    def handle_sock(sock, addr):
    
        #开线程接收客户端数据
        T_recive=threading.Thread(target=recive,args=(sock,))
        T_recive.start()
    
     #广播消息，若不在线删除
    def broadcast_data(sock, message):
        for socket in CONNECTION_LIST:
            if  socket != sock:
                try:
                    socket.send(message)
                except:
                    socket.close()
                    CONNECTION_LIST.remove(socket)
    
    
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.bind(('localhost', 10086))
    server.listen()
    CONNECTION_LIST = []
    
    #主线程循环接收客户端连接
    while True:
        sock, addr = server.accept()
        CONNECTION_LIST.append(sock)
        print('Connect--{}'.format(addr))
    
        #连接成功后开一个线程用于处理客户端
        client_thread = threading.Thread(target=handle_sock, args=(sock, addr))
        client_thread.start()

Client：

import socket
    import threading
    
    #接收数据
    def recive(client):
        while True:
            data = client.recv(1024)
            print("Recive:{}".format(data.decode("utf-8")))
    
    #连接服务器
    client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client.connect(('localhost', 10086))
    
    #开线程 用于接收数据
    t_recive=threading.Thread(target=recive, args=(client,))
    t_recive.start()
    
    #主线程用于发送数据
    while True:
        re_data = input()
        client.send(re_data.encode("utf-8"))
    # client.close()

安卓Java端-接收：

package Socket;
    
    import java.io.BufferedReader;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.net.Socket;
    
    public class client 
    { 
    	public static void main(String[] args) throws Exception { 
    		Socket client=new Socket("106.12.194.69",10010);
            InputStream is = client.getInputStream();
            while(true){ 
            	BufferedReader br = new BufferedReader(new InputStreamReader(is));
                String mess = br.readLine();
                System.out.println("服务器："+mess);
            }
    	}
    }

猜你喜欢

CloudCompare中CCCoreLib模块介绍
即将开源STD：用于3D位置识别的稳定三角形描述子
单测在商家前端业务中的实践
LOCUS 2.0：基于激光雷达的鲁棒且高效的3D实时建图
简析CloudCompare文件夹之间的关系
视觉在自动泊车系统中的设计与实现和挑战综述
八种常用激光雷达和视觉SLAM算法的评估与比较
SL sensor :一种基于结构光传感器开源且实时用于高精度建筑机器人重建应用方案
ROS2中零拷贝实现进程内节点之间的高效通信
多视觉异步SLAM系统
AI赋能智能交通“车路协同”场景，实现“聪明的车、智慧的路”！
maplab 2.0 多模态模块化建图框架
基于全景相机的深度学习综述
LOAM论文和程序代码的解读
LOAM论文和程序代码的解读（2）
实用干货：99%的人都不知道的一个Python技巧！
企业微信群机器人如何使用常见问题解答
面试必问：如何快速定位BUG？BUG定位技巧及N板斧！
2022年软件测试的五大趋势！！！
总结如何画一手好的架构图！！！

zl程序教程

当前栏目

python Socket服务器转发

相关文章