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

使用socket模拟数据流计算

时间:2017-05-23 10:19:40      阅读:194      评论:0      收藏:0      [点我收藏+]

标签:end   发送   bsp   code   文件的   and   blog   scoket   read   

场景描述:

客户端读取一个文件的每一行

与服务端建立scoket链接

服务端接收客户端发送的数据

服务端将文件写到本地

 

客户端代码:

import socket
import time
obj = socket.socket()

obj.connect(("192.168.169.133",8080))

ret_bytes = obj.recv(1024)
ret_str = str(ret_bytes,encoding="utf-8")
#print(ret_str)
filename ="d:/part-r-00000.txt"

while True: 
    inp =""
    if inp == "q":
        obj.sendall(bytes(inp,encoding="utf-8"))
        break
    else:
        for line in open(filename): 
            time.sleep(1/20)
            inp = line
            obj.sendall(bytes(inp, encoding="utf-8"))
            ret_bytes = obj.recv(1024)
            ret_str = str(ret_bytes,encoding="utf-8")
            print(ret_str)

 

服务端代码:

import  socketserver
#服务端

class Myserver(socketserver.BaseRequestHandler):

    def handle(self):
        f=open(f.txt,a)

        conn = self.request
        conn.sendall(bytes("你好,我是机器人",encoding="utf-8"))
        while True:
            ret_bytes = conn.recv(1024)
            ret_str = str(ret_bytes,encoding="utf-8")
            f.write(ret_str) 
            f.write(\n) 
            if ret_str == "q":
                break
            conn.sendall(bytes(ret_str+"你好我好大家好",encoding="utf-8"))
        
        f.close()

if __name__ == "__main__":
    server = socketserver.ThreadingTCPServer(("192.168.169.133",8080),Myserver)
    server.serve_forever()

 

使用socket模拟数据流计算

标签:end   发送   bsp   code   文件的   and   blog   scoket   read   

原文地址:http://www.cnblogs.com/kevinlucky/p/6892502.html

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