文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

python3-socketserver

2023-01-31 02:18

关注

目录

socketserver模块

基于TCP链接的简单并发程序

基于UDP无链接的简单并发程序

错误笔记:

ConnectionAbortedError: [WinError 10053] 你的主机中的软件中止了一个已建立的连接。

ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝,无法连接。


 

  模块socketserver是标准库提供的服务器框架基础.

这个框架包括了BaseHTTPServer , SimpleHTTPServer , CGIHTTPServer , SimpleXMLRPCServer , DocXMLRPCServer

等服务器,他们在基本服务器的基础上添加了各种功能。

  socketserver包含了4个基本的服务器

                        1.TCPServer(支持TCP套接字流)

                        2.UDPServer(支持UDP数据报套接字)

                        3.UnixStreamServer和UnixDatagramServer

编写服务端底层流程:

   服务器接受客户端连接请求——》实例话一个请求处理程序——》根据服务器类和请求处理程序类,调用处理方法。

例如:

   基本请求程序类(BaseRequestHandler)调用方法 handle 。此方法通过属性 self.request 来访问客户端套接字、

   StreamRequestHandler类(处理流),通过属性self.rfile(用于读取)和self.wfile(用于写入),进行与客户端通信

 

基于tcp的socketserver,自定义类中:

      conn,client_addr=socket(AF_INET,SOCK_STREAM)

  1.   self.server即套接字对象  <socketserver.ThreadingTCPServer object at 0x000001DA1221FB00>
  2.   self.request即一个链接  self.request = conn ; 如: <socket.socket fd=472, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 8080), raddr=('127.0.0.1', 59405)>
  3.   self.client_address即客户端地址 self.client_address = client_addr  ; ('127.0.0.1', 59405)                                                                            

基于udp的socketserver,自定义类中:

  1.   self.request是一个元组(第一个元素是客户端发来的数据,第二部分是服务端的udp套接字对象)                                      如:(b'adsf', <socket.socket fd=200, family=AddressFamily.AF_INET, type=SocketKind.SOCK_DGRAM, proto=0, laddr=('127.0.0.1', 8080)>)
  2.   self.client_address即客户端地址 ('127.0.0.1', 50323)

基于TCP链接的简单并发程序

 

服务端:


import socketserver


# 自定义类来实现通信循环
class MyTCPHandler(socketserver.BaseRequestHandler):
    # 必须写入handle方法,建立链接时会自动执行handle方法
    def handle(self):
        while True:
            try:
                data = self.request.recv(1024)
                if not data: break
                print('->client:', data)
                self.request.send(data.upper())
            except ConnectionResetError:
                break
        self.request.close()


if __name__ == '__main__':
    server = socketserver.ThreadingTCPServer(('127.0.0.1', 8080), MyTCPHandler)
    server.serve_forever()  # 链接循环

客户端1/2/3/4……


import socket

client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
client.connect(('127.0.0.1',8080))

while True:
    client.send('hello'.encode('utf-8'))
    data = client.recv(1024)
    print(data)

基于UDP无链接的简单并发程序

 

服务端:


import socketserver


# 自定义类来实现通信循环
class MyUDPHander(socketserver.BaseRequestHandler):
    def handle(self):
        data,sock = self.request
        sock.sendto(data.upper(),self.client_address)

if __name__ == '__main__':
    server = socketserver.ThreadingUDPServer(('127.0.0.1', 8080), MyUDPHander)
    server.serve_forever()  # 链接循环

 

客户端1/2/3/4……:


from socket import *

client = socket(AF_INET,SOCK_DGRAM)

while True:
    client.sendto(b'hello',('127.0.0.1',8080))
    data,server_add = client.recvfrom(1024)
    print(data)

错误笔记:

ConnectionAbortedError: [WinError 10053] 你的主机中的软件中止了一个已建立的连接。

- 服务端代码错误

- 解决方法:自定义handler类内必须写入handle方法

ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝,无法连接。

- 解决方法:kill相关进程重新启动

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯