Question

如何解决python socket server重启后端口被占用的问题

Answer 1

本文介绍下，在solaris 系统下，python socket server重启后，提示端口被占用，telnet端口失败。这里给出一个解决方法，有需要的朋友参考下。

在solaris 系统下，socket server被重启后，提示端口被占用，telnet端口又是不成功的，说明服务已被关闭。
通过netstat可以看到端口还处于于fin_wait_2状态，solaris要4分钟才能关闭。
遇到这个问题时，可以采用如下的方法解决，以减少等待时间。
1，加上s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)。
代码：

复制代码代码示例:
self.host=socket.gethostbyname(socket.gethostname())
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind((self.host,self.port))
s.listen(5)
2，修改系统fin_wait,time_wait的时间设置。这个时间改短，也利于系统系能。
修改方法
查看或设置：
使用get命令来确定当前时间间隔，并使用set命令将时间间隔指定为30秒。
例如:

复制代码代码示例:
ndd -get /dev/tcp tcp_time_wait_interval
ndd -set /dev/tcp tcp_time_wait_interval 30000
缺省值：对于 Solaris 操作系统，缺省等待时间间隔为 240000 毫秒（即 4 分钟）。
建议值：60000 毫秒。
Solaris TCP_FIN_WAIT_2_FLUSH_INTERVAL
描述：
指定禁止处于FIN_WAIT_2状态的连接保持该状态的计时器时间间隔。
当连接比率较高时，这将累积大量的TCP/IP连接，从而导致服务器性能下降。在高峰时间段，服务器会发 生延迟。
如果服务器延迟，netstat命令显示对HTTP Server打开的许多套接字处于CLOSE_WAIT或FIN_WAIT_2状态。
明显的延迟可能会长达4分钟，其间服务器无法发送任何响应，但是CPU利用率保持很高，所有活动都在系统进程中。
查看和设置：
使用get命令来确定当前时间间隔，并使用set命令将时间间隔指定为67.5秒。
例如:

复制代码代码示例:
ndd -get /dev/tcp tcp_fin_wait_2_flush_interval
ndd -set /dev/tcp tcp_fin_wait_2_flush_interval 67500
缺省值：675000 毫秒
建议值：67500 毫秒
Solaris TCP_KEEPALIVE_INTERVAL
描述：
“保持活动”包确保连接保持活动和已建立状态。
查看或设置：
使用ndd命令来确定当前值或设置该值。
例如：

复制代码代码示例:
ndd -set /dev/tcp tcp_keepalive_interval 300000
缺省值：7200000 毫秒
建议值：15000 毫秒

Answer 2

可以使用socketserver模块

import socketserver
class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        """
        self.request=======conn
        :return:
        """
        while 1:
            try:
                data = self.request.recv(1024).decode("utf8")  # 阻塞函数
                print("data", data)
                # 针对linux，ios系统
                if len(data) == 0 or data == "q":
                    break
                res = input("回复>>>").encode("utf8")
                self.request.sendall(res)
            # 针对window系统
            except Exception as e:
                break
        self.request.close()

server=socketserver.ThreadingTCPServer(("127.0.0.1",8008),MyServer)
server.serve_forever()