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

推荐订阅源

freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More
G
Google Developers Blog
Hugging Face - Blog
Hugging Face - Blog
博客园 - 【当耐特】
S
SegmentFault 最新的问题
宝玉的分享
宝玉的分享
博客园 - Franky
博客园_首页
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
WordPress大学
WordPress大学
有赞技术团队
有赞技术团队
月光博客
月光博客
博客园 - 聂微东
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
小众软件
小众软件
Microsoft Security Blog
Microsoft Security Blog
Last Week in AI
Last Week in AI
Vercel News
Vercel News
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
爱范儿
爱范儿
J
Java Code Geeks
博客园 - 叶小钗
Engineering at Meta
Engineering at Meta
阮一峰的网络日志
阮一峰的网络日志

博客园 - 西康的博客

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开发示例: