基于TCP的通信应用示例

106 阅读 0 评论 70 点赞

我是靠谱客的博主妩媚黑米，最近开发中收集的这篇文章主要介绍基于TCP的通信应用示例，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

如图，通过小程序，1台在海南的电脑与1台在上海的电脑成功进行了通信

准备工作：需要在运行服务端程序的电脑防火墙开放监听端口

基于Python实现TCP通信的方法：

1.在服务端程序创建TCP套接字对象，监听一个指定的端口

2.在客户端程序也创建TCP套接字对象，每次发送消息就链接到服务端并发送数据

3.服务端收到消息，并回复消息给客户端

服务端代码：

import socket
import threading
from tkinter import *
import sys


class Server:
    def __init__(self):
        """实现一个界面"""
        window = Tk()
        window.title('python通信测试(服务端)')
        window.geometry('400x200')
        self.txt1 = StringVar()
        self.txt2 = StringVar()
        entry1 = Entry(window, width=25, textvariable=self.txt1, font=('宋体', 20), fg='blue')
        entry2 = Entry(window, width=50, textvariable=self.txt2, state="readonly")
        entry1.pack()
        entry2.pack()
        window.after(0, self.run)
        window.mainloop()
        sys.exit()

    def run(self):
        t = threading.Thread(target=self.main)
        t.setDaemon(True)
        t.start()

    def main(self):
        while True:
            self.socket_func()

    def socket_func(self):
        # 1、创建一个TCP服务端套接字对象
        tcp_sever = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # 2. 绑定本地的相关信息，如果不绑定，则系统会随机分配一个端口号
        local_addr = ('', 1234)  # ip地址和端口号，ip一般不用写，表示本机的任何一个ip，需要在防火墙开放监听的端口
        tcp_sever.bind(local_addr)
        # 3、监听连接，使用socket创建的套接字默认的属性是主动的，使用listen将其变为被动的，这样就可以接收别人的链接了
        tcp_sever.listen(5)
        # 4、等待连接，其返回值为连接过来的客户端套接字对象和IP地址
        client_socket, client_addr = tcp_sever.accept()
        # 5、等待接收对方发送过来的数据
        recv_data = client_socket.recv(1024).decode("utf-8")  # 最大接收1024个字节
        comer = str(client_addr[0]) + ':' + str(client_addr[1])  # 消息来源
        message = "来自" + comer + "的消息："+recv_data
        print(message)
        self.txt1.set(recv_data)
        self.txt2.set(message)

        # 6、返回数据到客户端
        send_data = "服务器已接收到数据！" + recv_data
        client_socket.send(send_data.encode('utf-8'))
        # 7、关闭套接字
        tcp_sever.close()


if __name__ == '__main__':
    Server()

客户端代码：

import socket
import threading
from tkinter import *


class Clilent:
    def __init__(self):
        """实现一个界面"""
        self.window = Tk()
        self.window.title('python TCP通信测试(客户端)')
        self.window.geometry('400x200')
        self.recv_data = ""
        self.txt1 = StringVar()
        self.txt2 = StringVar()
        self.entry1 = Entry(self.window, width=25, textvariable=self.txt1, state="readonly", font=('宋体', 20), fg='blue')
        self.entry2 = Entry(self.window, width=25, textvariable=self.txt2, font=('宋体', 20))
        btn = Button(self.window, width=6, height=1, text='发送', command=self.run)
        self.entry1.pack()
        self.entry2.pack()
        btn.pack()
        self.window.mainloop()

    def run(self):
        t = threading.Thread(target=self.send_func)
        t.start()

    def update(self):
        self.txt1.set(self.recv_data)

    def send_func(self):
        self.txt1.set('')
        # 1、准备服务端的地址和端口，'192.168.0.107'表示目的ip地址，12341表示目的端口号
        dest_addr = ('192.168.0.107', 1234)  # 注意这是一个元组，其中ip地址是字符串，端口号是数字
        # 2、创建一个TCP客户端套接字对象
        tcp_client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # 3、链接到服务器
        tcp_client.connect(dest_addr)
        # 4、发送数据
        send_txt = self.entry2.get()
        tcp_client.send(send_txt.encode("utf-8"))
        # 5、等待接收服务端发送过来的数据，最大接收1024个字节
        self.recv_data = tcp_client.recv(1024).decode("utf-8")
        self.window.after(0, self.update)
        # 6、将接收到的数据打印出来
        print(self.recv_data)
        # 7、关闭套接字
        tcp_client.close()


if __name__ == '__main__':
    Clilent()