TCP绑定双端口传输数据

素颜马尾好姑娘i 2022-04-25 07:08 488阅读 0赞

### 文章目录 ###

*  1.环境
 *  2.服务端代码
 *  3.打开网络调试工具

参考： [https://blog.csdn.net/weixin\_33721344/article/details/89663010][https_blog.csdn.net_weixin_33721344_article_details_89663010]

# 1.环境 #

windows10  
python3.6  
网络调试助手工具NetAssist  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hb2Vyc29uZw_size_16_color_FFFFFF_t_70]

# 2.服务端代码 #

# -*- coding: utf-8 -*-
    """
    @desc: tcp两个端口转发，从一个端口发数据，可以从另一个端口接数据
    """
    import socket
    import threading
    import signal
    import sys
    
    REMOTE_IP = ''#不绑定IP，远程电脑可以访问该机器
    LOCAL_IP = ''
    REMOTE_PORT = 10002
    LOCAL_PORT = 10001
    # 接收数据缓存大小
    PKT_BUFF_SIZE = 4096
    
    # 调试日志封装
    def send_log(content):
        print (content)
        return
    
    # 单向流数据传递
    def tcp_mapping_worker(conn_receiver, conn_sender):
        while True:
            try:
                data = conn_receiver.recv(PKT_BUFF_SIZE)
            except Exception:#当与服务socket断开连接时
                send_log('Event: Connection closed.')
                break
     
            if not data:
                send_log('Info: No more data is received.')
                break
         
            try:
                conn_sender.sendall(data)
            except Exception:
                send_log('Error: Failed sending data.')
                break
         
            # send_log('Info: Mapping data > %s ' % repr(data))
            send_log('Info: Mapping > %s -> %s > %d bytes.' % (conn_receiver.getpeername(), conn_sender.getpeername(), len(data)))
     
        conn_receiver.close()
        conn_sender.close()
        return
    
    def main():
        local_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        remote_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        send_log("1.套接字创建完毕.") 
    
        local_server.bind((LOCAL_IP,LOCAL_PORT))
        remote_server.bind((REMOTE_IP,REMOTE_PORT))
        send_log("2.端口绑定完毕.")
        
        #监听端口，最大连接数量128
        local_server.listen(128)
        remote_server.listen(128)
        send_log("3.监听两端端口.")
    
        while True: 
            # 接收到新的客户端连接则创建服务套接字
            send_log("4.等待两端客户端连接 %s:%d %s:%d" %(LOCAL_IP,LOCAL_PORT,REMOTE_IP,REMOTE_PORT))
            (local_conn, local_addr) = local_server.accept()
            (remote_conn, remote_addr) = remote_server.accept()
            send_log("5.两端客户端连接端口成功.") 
            #LOCAL_PORT端口数据转发给REMOTE_PORT端口
            thread1 = threading.Thread(target=tcp_mapping_worker, args=(local_conn, remote_conn))
            thread1.start()
            #REMOTE_PORT端口数据转发给LOCAL_PORT端口
            thread2 = threading.Thread(target=tcp_mapping_worker, args=(remote_conn, local_conn))
            thread2.start()
            
            #join()作用为主线程在所有子线程执行完之后才执行
            thread1.join()  
            thread2.join()    
        send_log("执行完成")
        
    if __name__ == "__main__":
        main()

# 3.打开网络调试工具 #

互相发送数据都可以。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hb2Vyc29uZw_size_16_color_FFFFFF_t_70 1]

[https_blog.csdn.net_weixin_33721344_article_details_89663010]: https://blog.csdn.net/weixin_33721344/article/details/89663010
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hb2Vyc29uZw_size_16_color_FFFFFF_t_70]: /images/20220126/4e5c502438d84ea0887959db3531e18f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hb2Vyc29uZw_size_16_color_FFFFFF_t_70 1]: /images/20220126/29017f9c18f84c1d90155d61c9c9bae7.png