码迷,mamicode.com
首页 > 其他好文 > 详细

socketserver实现并发

时间:2019-02-25 10:33:45      阅读:196      评论:0      收藏:0      [点我收藏+]

标签:地址   _for   cli   decode   nbsp   信息   ever   forever   封装   

我们之前写的tcp协议的socket是不是一次只能和一个客户端通信,如果用socketserver可以实现和多个客户端通信。它是在socket的基础上进行了一层封装,也就是说底层还是调用的socket,在py2.7里面叫做SocketServer也就是大写了两个S,在py3里面就小写了。后面我们要写的FTP作业,需要用它来实现并发,也就是同时可以和多个客户端进行通信,多个人可以同时进行上传下载等。

 
  那么我们先看socketserver怎么用呢,然后在分析,先看下面的代码
技术图片
import socketserver  # 引入模块

class MyServer(socketserver.BaseRequestHandler):   # 类名随便定义,但是必须继承socketserver.BaseRequestHandler此类
    
    def handle(self):  # 写一个handle方法,固定名字
        while 1:
            # self.request 相当于conn管道
            from_client_data = self.request.recv(1024).decode(‘utf-8‘)
            print(from_client_data)
            to_client_data = input(‘服务端回信息:‘).strip()
            self.request.send(to_client_data)
            


if __name__ == ‘__main__‘:
    ip_port = (‘127.0.0.1‘,8080)
    socketserver.TCPServer.allow_reuse_address = True  # 允许端口重用
    server = socketserver.ThreadingTCPServer(ip_port,MyServer)
    # 对 socketserver.ThreadingTCPServer 类实例化对象,将ip地址,端口号以及自己定义的类名传入,并返回一个对象
    server.serve_forever() # 对象执行serve_forever方法,开启服务端

 

import socket
client = socket.socket()
client.connect((127.0.0.1,8888))

while 1:
    to_server_data = input(>>>).strip().encode(utf-8)
    client.send(to_server_data)
    from_server_data = client.recv(1024).decode(utf-8)
    print(from_server_data)

 

socketserver实现并发

标签:地址   _for   cli   decode   nbsp   信息   ever   forever   封装   

原文地址:https://www.cnblogs.com/YZL2333/p/10429451.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!