TCP服务端和客户端问题
本帖最后由 wnhuiyou 于 2021-1-15 14:21 编辑我写了一个简单的TCP服务器和一个TCP客户端，现在遇到这么一个问题，TCP服务端可以一直挂在后台，但是第一次客户端请求的时候，是没有任何问题，也能够进行发送数据，但是只要把客户端关闭了，再次开启就会报错：
OSError: 通常每个套接字地址(协议/网络地址/端口)只允许使用一次。
还有一个报错就是，快速的点击 音量+ 的时候就会崩溃，慢点点击就没有问题
然后把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)
服务端改成socketserver模块试试 可能是只有一层while True不够 自带的serve_forever可以试试看
server = socketserver.TCPServer(("127.0.0.1", 9999), 你的类)
# 让server永远运行下去，除非强制停止程序
server.serve_forever() # 设置allow_reuse_address允许服务器重用地址
socketserver.TCPServer.allow_reuse_address = True
忘了说还有这个参数 import socket
from socket import SOL_SOCKET,SO_REUSEADDR
sk = socket.socket()
sk.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
要在sk.bind之前调用
在此之前你先试试这个这个专门对付报错OSError: Address already in use kogawananari 发表于 2021-1-16 14:22
服务端改成socketserver模块试试 可能是只有一层while True不够 自带的serve_forever可以试试看
server...
谢谢你，后面我通过UDP的方式好像更方便了，但不知道有没有安全隐患...UDP方式实现好吗？
页:
[1]