import socketserverclass MyTCPserver(socketserver.BaseRequestHandler):def handle(self):while True:try:self.data=self.request.recv(1024).strip()print("您已经接收数据:",self.data)self.request.sendall(self.data.upper())print("您已经发送数据:")except ConnectionResetError as e:breakhost,port="127.0.0.1",6000
serverTCP = socketserver.TCPServer(("127.0.0.1", 6000), MyTCPserver)
print("***连接成功***")
#server=socketserver.ThreadingTCPServer((host,port),MyTCPserver)
serverTCP.serve_forever()import socketclient=socket.socket()
client.connect((&#39;127.0.0.1&#39;,6000))while True:msg&#61;input("<<请输入").strip()if len(msg)&#61;&#61;0:continuess&#61;client.send(msg.encode(&#39;utf-8&#39;))print("send:",ss)data &#61; client.recv(1024)print(data.decode(&#39;utf-8&#39;))
client.close
遇到了bug,因为我之前用过这个端口,没有停掉
这个问题肯定是server的问题,要不是server写错了,要不是先开启了client
我是把handle写成了handler一直进不去这个函数,后来注意到这个是继承的前面肯定有override的标识
self.request就是socket中的server.accept()接收到的request是一致的.
代码的思路
1. 创建一个请求处理的类&#xff0c;并且这个类要继承BaseRequestHandlerclass &#xff0c;并且还要重写父类里handle()方法&#xff1b;
2. 你必须实例化 TCPServer&#xff0c;并且传递server IP和你上面创建的请求处理类&#xff0c;给这个TCPServer&#xff1b;
3. server.handle_requese()#只处理一个请求&#xff0c;server.server_forever()处理多个一个请求&#xff0c;永远执行
4. 关闭连接server_close()
fileno&#xff08;&#xff09;
返回服务器正在侦听的套接字的整数文件描述符。这个函数通常被传递给选择器&#xff0c;允许在同一个进程中监视多个服务器。handle_request&#xff08;&#xff09;
处理一个请求。该函数按顺序调用以下方法&#xff1a;get_request&#xff08;&#xff09;&#xff0c;verify_request&#xff08;&#xff09;和process_request&#xff08;&#xff09;。如果处理程序类的用户提供的handle&#xff08;&#xff09;方法引发异常&#xff0c;则将调用服务器的handle_error&#xff08;&#xff09;方法。如果在超时秒内没有收到请求&#xff0c;则会调用handle_timeout&#xff08;&#xff09;&#xff0c;并返回handle_request&#xff08;&#xff09;。serve_forever&#xff08;POLL_INTERVAL &#61; 0.5&#xff09;
处理请求直到显式关闭&#xff08;&#xff09;请求。轮询关闭每个poll_interval秒。忽略超时属性。它还调用service_actions&#xff08;&#xff09;&#xff0c;子类或mixin可以使用它来提供特定于给定服务的操作。例如&#xff0c;ForkingMixIn类使用service_actions&#xff08;&#xff09;来清理僵尸子进程。在版本3.3中进行了更改&#xff1a;将service_actions调用添加到了serve_forever方法。service_actions&#xff08;&#xff09;
这在serve_forever&#xff08;&#xff09;循环中被调用。这个方法可以被子类或mixin类覆盖&#xff0c;以执行特定于给定服务的操作&#xff0c;例如清理操作。3.3版本中的新功能shutdown()
告诉serve_forever&#xff08;&#xff09;循环停止并等待&#xff0c;直到它结束。server_close&#xff08;&#xff09;
清理服务器。可能会被覆盖。address_family
服务器套接字所属的协议族。通常的例子是socket.AF_INET和socket.AF_UNIX。RequestHandlerClass
用户提供的请求处理程序类;这个类的一个实例是为每个请求创建的。server_address服务器正在侦听的地址。地址格式因协议族而异&#xff0c;有关详细信息&#xff0c;请参阅套接字模块的文档。对于Internet协议&#xff0c;这是一个包含给出地址的字符串的元组&#xff0c;以及一个整数端口号&#xff1a;&#xff08;&#39;127.0.0.1&#39;&#xff0c;80&#xff09;。socket
服务器将侦听传入请求的套接字对象。服务器类支持以下类变量&#xff1a;allow_reuse_address
服务器是否允许重用地址。这默认为False&#xff0c;可以在子类中设置来更改策略。request_queue_size
请求队列的大小。如果处理单个请求需要很长时间&#xff0c;则在服务器繁忙时到达的所有请求都会被放入一个队列中&#xff0c;最多为request_queue_size请求。一旦队列已满&#xff0c;来自客户端的进一步请求将会得到“连接被拒绝”错误。默认值通常是5&#xff0c;但这可以由子类覆盖。socket_type
服务器使用的套接字的类型; socket.SOCK_STREAM和socket.SOCK_DGRAM是两个常见的值。timeout
超时持续时间&#xff08;以秒为单位&#xff09;;如果不需要超时&#xff0c;则超时。如果handle_request&#xff08;&#xff09;在超时期限内没有收到传入的请求&#xff0c;则调用handle_timeout&#xff08;&#xff09;方法。有许多服务器方法可以被TCPServer等基本服务器类的子类覆盖;这些方法对服务器对象的外部用户没有用处。finish_request&#xff08;&#xff09;
实际上通过实例化RequestHandlerClass并调用其handle&#xff08;&#xff09;方法来处理请求。get_request&#xff08;&#xff09;
必须接受来自套接字的请求&#xff0c;并返回包含要用于与客户端通信的新套接字对象的2元组以及客户端的地址。handle_error&#xff08;request&#xff0c;client_address&#xff09;
如果RequestHandlerClass实例的handle&#xff08;&#xff09;方法引发异常&#xff0c;则调用此函数。默认操作是将回溯打印到标准输出&#xff0c;并继续处理更多的请求。handle_timeout&#xff08;&#xff09;
当timeout属性被设置为None以外的值时&#xff0c;该函数被调用&#xff0c;超时时间已经过去&#xff0c;没有收到请求。派生服务器的默认动作是收集退出的任何子进程的状态&#xff0c;而在线程服务器中&#xff0c;这个方法什么也不做。process_request&#xff08;request&#xff0c;client_address&#xff09;
调用finish_request&#xff08;&#xff09;来创建RequestHandlerClass的一个实例。如果需要&#xff0c;这个函数可以创建一个新的进程或线程来处理请求; ForkingMixIn和ThreadingMixIn类都是这样做的。server_activate&#xff08;&#xff09;
由服务器的构造函数调用以激活服务器。 TCP服务器的默认行为只是在服务器套接字上调用listen&#xff08;&#xff09;。可能会被覆盖。server_bind&#xff08;&#xff09;
由服务器的构造函数调用&#xff0c;将套接字绑定到所需的地址。可能会被覆盖。verify_request&#xff08;request&#xff0c;client_address&#xff09;
必须返回一个布尔值;如果值为True