[已解决]TCP服务端和客户端问题

wnhuiyou

我写了一个简单的TCP服务器和一个TCP客户端，现在遇到这么一个问题，TCP服务端可以一直挂在后台，但是第一次客户端请求的时候，是没有任何问题，也能够进行发送数据，但是只要把客户端关闭了，再次开启就会报错：

OSError: [WinError 10048] 通常每个套接字地址(协议/网络地址/端口)只允许使用一次。

还有一个报错就是，快速的点击 音量+ 的时候就会崩溃，慢点点击就没有问题

然后把TCP服务器关闭了，再开启又好了，这样太麻烦了，我想TCP服务端一直挂在后台不断线，然后客户端需要连接的时候就打开软件，不需要的时候就关闭，再次打开时一样能够正常发送数据，服务端也能够正常接收数据，我真的是不知道怎么修改了，请教下大家，代码我放在下面

客户端：

import os
import sys
import socket

from PyQt5.Qt import QWidget, QApplication
from PyQt5.QtWidgets import QPushButton, QLabel, QAction, QMenu, QLineEdit


class YC(QWidget):

    def __init__(self):
        super().__init__()

        self.tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.tcp_socket.bind(("127.0.0.1", 8082))

        self.server = ('127.0.0.1', 8081)
        self.tcp_socket.connect(self.server)

        # 按钮
        self.QPushButton("音量+", "font:30px", 100, 50, 40, 50, self.TKS)
        self.QPushButton("音量-", "font:30px", 100, 50, 160, 70, self.TKS)
        self.QPushButton("重启", "font:30px", 100, 50, 160, 130, self.TKS)
        self.QPushButton("关机", "font:30px", 100, 50, 40, 130, self.TKS)

    # 标题
    def QLabel(self, Text, StyleSheet, move_x, move_y):
        label = QLabel(self)
        label.setText(Text)
        label.setStyleSheet(StyleSheet)
        label.move(move_x, move_y)

    # 按钮
    def QPushButton(self, Text, StyleSheet, resize_x, resize_y, move_x, move_y, clicked):
        btn = QPushButton(self)
        btn.setText(Text)
        btn.setStyleSheet(StyleSheet)
        btn.resize(resize_x, resize_y)
        btn.move(move_x, move_y)
        btn.clicked.connect(clicked)

    # 输入框
    def QLineEdit(self, setText, move_x, move_y):
        Input = QLineEdit(self)
        Input.setText(setText)
        Input.resize(155, 30)
        Input.move(move_x, move_y)
        Input.setStyleSheet("font:20px")
        return Input

    # 连接
    def TKS(self):
        self.tcp_socket.send('1'.encode("gbk"))


if __name__ == '__main__':
    app = QApplication(sys.argv)
    win = YC()
    win.setWindowTitle("自助机遥控器")
    win.setFixedSize(300, 240)  # 设定固定窗口大小

    win.show()
    sys.exit(app.exec_())

--------------------------------------------------------------------------------------------------------

服务端：

import socket
import time

tcp_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

tcp_server.bind(("", 8081))

tcp_server.listen(128)

tcp_server.setblocking(False)  # 设置套接字为非堵塞

client_socket_list = list()

while True:

    time.sleep(1)
    try:
        new_socket, new_addr = tcp_server.accept()  # 接受一个客户端的请求

    except Exception as ret:
        # print(ret)
        print("等待连接")

    else:
        print("连接成功")
        new_socket.setblocking(False)   # 设置为非堵塞
        client_socket_list.append(new_socket)

    for client_socket in client_socket_list:
        try:
            recv_data = client_socket.recv(1024)
        except Exception as ret:
            # print(ret)
            print("---没有发送指令---")
        else:

            # 音量增加
            if recv_data.decode("GBK") == '1':
                # 音量增加
                
                print(recv_data.decode("GBK"), '接收成功-----------------------------------------------')

            # 音量减少
            elif recv_data.decode("GBK") == '2':
                # 音量减少
              
                print(recv_data.decode("GBK"), '接收成功')

            # 关机
            elif recv_data.decode("GBK") == '3':
                # 关机
                
                print(recv_data.decode("GBK"), '接收成功')

            # 重启
            elif recv_data.decode("GBK") == '4':
                # 重启
               
                print(recv_data.decode("GBK"), '接收成功')

            else:
                client_socket.close()
                client_socket_list.remove(client_socket)

最佳答案

月排行榜 / 总排行榜

kogawananari

2021-1-16 14:22:40

服务端改成socketserver模块试试 可能是只有一层while True不够 自带的serve_forever可以试试看

server = socketserver.TCPServer(("127.0.0.1", 9999), 你的类)
# 让server永远运行下去，除非强制停止程序
server.serve_forever()

跳转到最佳答案楼层

kogawananari

服务端改成socketserver模块试试 可能是只有一层while True不够 自带的serve_forever可以试试看

server = socketserver.TCPServer(("127.0.0.1", 9999), 你的类)
# 让server永远运行下去，除非强制停止程序
server.serve_forever()

kogawananari

# 设置allow_reuse_address允许服务器重用地址
    socketserver.TCPServer.allow_reuse_address = True
忘了说还有这个参数

kogawananari

import socket
from socket import SOL_SOCKET,SO_REUSEADDR
sk = socket.socket()
sk.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
要在sk.bind之前调用
在此之前你先试试这个  这个专门对付报错OSError: [Error 48] Address already in use

wnhuiyou

kogawananari 发表于 2021-1-16 14:22
服务端改成socketserver模块试试 可能是只有一层while True不够 自带的serve_forever可以试试看

server  ...

谢谢你，后面我通过UDP的方式好像更方便了，但不知道有没有安全隐患...UDP方式实现好吗？