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

wnhuiyou

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

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

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

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

客户端：

1. import os
   
2. import sys
   
3. import socket
   
4. 
   
5. from PyQt5.Qt import QWidget, QApplication
   
6. from PyQt5.QtWidgets import QPushButton, QLabel, QAction, QMenu, QLineEdit
   
7. 
   
8. 
   
9. class YC(QWidget):
   
10. 
    
11.     def __init__(self):
    
12.         super().__init__()
    
13. 
    
14.         self.tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
15.         self.tcp_socket.bind(("127.0.0.1", 8082))
    
16. 
    
17.         self.server = ('127.0.0.1', 8081)
    
18.         self.tcp_socket.connect(self.server)
    
19. 
    
20.         # 按钮
    
21.         self.QPushButton("音量+", "font:30px", 100, 50, 40, 50, self.TKS)
    
22.         self.QPushButton("音量-", "font:30px", 100, 50, 160, 70, self.TKS)
    
23.         self.QPushButton("重启", "font:30px", 100, 50, 160, 130, self.TKS)
    
24.         self.QPushButton("关机", "font:30px", 100, 50, 40, 130, self.TKS)
    
25. 
    
26.     # 标题
    
27.     def QLabel(self, Text, StyleSheet, move_x, move_y):
    
28.         label = QLabel(self)
    
29.         label.setText(Text)
    
30.         label.setStyleSheet(StyleSheet)
    
31.         label.move(move_x, move_y)
    
32. 
    
33.     # 按钮
    
34.     def QPushButton(self, Text, StyleSheet, resize_x, resize_y, move_x, move_y, clicked):
    
35.         btn = QPushButton(self)
    
36.         btn.setText(Text)
    
37.         btn.setStyleSheet(StyleSheet)
    
38.         btn.resize(resize_x, resize_y)
    
39.         btn.move(move_x, move_y)
    
40.         btn.clicked.connect(clicked)
    
41. 
    
42.     # 输入框
    
43.     def QLineEdit(self, setText, move_x, move_y):
    
44.         Input = QLineEdit(self)
    
45.         Input.setText(setText)
    
46.         Input.resize(155, 30)
    
47.         Input.move(move_x, move_y)
    
48.         Input.setStyleSheet("font:20px")
    
49.         return Input
    
50. 
    
51.     # 连接
    
52.     def TKS(self):
    
53.         self.tcp_socket.send('1'.encode("gbk"))
    
54. 
    
55. 
    
56. if __name__ == '__main__':
    
57.     app = QApplication(sys.argv)
    
58.     win = YC()
    
59.     win.setWindowTitle("自助机遥控器")
    
60.     win.setFixedSize(300, 240)  # 设定固定窗口大小
    
61. 
    
62.     win.show()
    
63.     sys.exit(app.exec_())
    

复制代码

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

服务端：

1. import socket
   
2. import time
   
3. 
   
4. tcp_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
   
5. 
   
6. tcp_server.bind(("", 8081))
   
7. 
   
8. tcp_server.listen(128)
   
9. 
   
10. tcp_server.setblocking(False)  # 设置套接字为非堵塞
    
11. 
    
12. client_socket_list = list()
    
13. 
    
14. while True:
    
15. 
    
16.     time.sleep(1)
    
17.     try:
    
18.         new_socket, new_addr = tcp_server.accept()  # 接受一个客户端的请求
    
19. 
    
20.     except Exception as ret:
    
21.         # print(ret)
    
22.         print("等待连接")
    
23. 
    
24.     else:
    
25.         print("连接成功")
    
26.         new_socket.setblocking(False)   # 设置为非堵塞
    
27.         client_socket_list.append(new_socket)
    
28. 
    
29.     for client_socket in client_socket_list:
    
30.         try:
    
31.             recv_data = client_socket.recv(1024)
    
32.         except Exception as ret:
    
33.             # print(ret)
    
34.             print("---没有发送指令---")
    
35.         else:
    
36. 
    
37.             # 音量增加
    
38.             if recv_data.decode("GBK") == '1':
    
39.                 # 音量增加
    
40.                
    
41.                 print(recv_data.decode("GBK"), '接收成功-----------------------------------------------')
    
42. 
    
43.             # 音量减少
    
44.             elif recv_data.decode("GBK") == '2':
    
45.                 # 音量减少
    
46.               
    
47.                 print(recv_data.decode("GBK"), '接收成功')
    
48. 
    
49.             # 关机
    
50.             elif recv_data.decode("GBK") == '3':
    
51.                 # 关机
    
52.                
    
53.                 print(recv_data.decode("GBK"), '接收成功')
    
54. 
    
55.             # 重启
    
56.             elif recv_data.decode("GBK") == '4':
    
57.                 # 重启
    
58.                
    
59.                 print(recv_data.decode("GBK"), '接收成功')
    
60. 
    
61.             else:
    
62.                 client_socket.close()
    
63.                 client_socket_list.remove(client_socket)
    
64. 
    
65. 
    
66. 
    
67. 
    

复制代码

最佳答案

月排行榜 / 总排行榜

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方式实现好吗？