惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

WordPress大学
WordPress大学
酷 壳 – CoolShell
酷 壳 – CoolShell
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
腾讯CDC
freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
Jina AI
Jina AI
N
Netflix TechBlog - Medium
有赞技术团队
有赞技术团队
博客园 - 【当耐特】
MongoDB | Blog
MongoDB | Blog
P
Proofpoint News Feed
L
LangChain Blog
aimingoo的专栏
aimingoo的专栏
GbyAI
GbyAI
B
Blog
F
Fortinet All Blogs
T
Tailwind CSS Blog
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
G
Google Developers Blog
A
About on SuperTechFans
C
Check Point Blog
Microsoft Security Blog
Microsoft Security Blog
MyScale Blog
MyScale Blog
B
Blog RSS Feed

博客园 - 西康的博客

mysql information_schema库中COLUMNS 和 TABLES表字段详解 python - queue 队列模块 python - 修改系统环境变量 python - threading 多进程模块 python - 反射 python - socket 基础 python 序列化 字典 异常处理 类的成员,类的特殊方法 elasticsearch RESTfull _cat api python - 面向对象编程基础知识 (进阶) python - 面向对象编程基础知识 python 文件操作 python re 模块 正则表达式 python configparser 模块 python logging 模块 python hashlib 模块 python sys 模块
python - socketserver
西康的博客 · 2018-04-25 · via 博客园 - 西康的博客

实现socket并发

import socketserver

buffer_size = 1024
ip_port = ('127.0.0.1',8080)


class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        print (self.request)
        print (self.client_address)

        while True:
            try:
                msg = self.request.recv(buffer_size)
                if not msg:
                    break
                print ('收到服务端的消息是:',msg)

                self.request.sendall(msg.upper())

            except Exception as e:
                print (e)

if __name__ == '__main__':
    tcp_server = socketserver.ThreadingTCPServer(ip_port,MyServer)
    tcp_server.serve_forever()

服务端-基本并发

import socketserver

buffer_size = 1024
ip_port = ('127.0.0.1',8080)


class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        print (self.request)
        print (self.client_address)

        while True:
            try:
                msg = self.request.recv(buffer_size)
                if not msg:
                    break
                print ('收到服务端的消息是:',msg)

                self.request.sendall(msg.upper())

            except Exception as e:
                print (e)

if __name__ == '__main__':
    tcp_server = socketserver.ThreadingTCPServer(ip_port,MyServer)
    tcp_server.serve_forever()

客户端-基本并发

FTP server和client开发示例: