socketserve及其应用

1.cmd命令利用socket

socket服务端

 import socket

 import subprocess

 s = socket.socket()

 s.bind(("127.0.0.1",8000))

 s.listen(3)

 print("waiting...")

 while 1:

     conn,addr = s.accept()

     print(conn)

     while 1:

         try:

             a = conn.recv(1024)

         except Exception:

             break

         if not a:

             break

         print(">>>",str(a,"utf8"))

         obj  = subprocess.Popen(a.decode("utf8"),shell=True,stdout=subprocess.PIPE)

         result = obj.stdout.read()

         print('ooooo',type(result))

         result_len = bytes(str(len(result)),"utf8") # result是unicode编码下的十六进制 所以先转换成字符串（Unicode） 在转换成bytes

         conn.sendall(result_len)  # 两个send在一起容易发生粘包 特别是第一个数据特别小的时候

         conn.sendall(result)      # 所以在send之间在来个一收一发

 s.close()

client客户端

 import socket

 s = socket.socket()

 ss = ("127.0.0.1",8000)

 s.connect(ss)

 while 1:

     inp = input(">>>")

     if inp =="q":

         break

     s.send(bytes(inp,"utf8"))    # send 传送智能是bytes类型

     result_len = int(str(s.recv(1024),"utf8"))    # 二进制的不能直接转换成整形！！！

     print(result_len)

     data = bytes()

     while len(data)!=result_len:    # 大文件传输过程中  不能一次传完 造成延迟 所以要先

         data += s.recv(1024)    # 传输文件的大小 根据大小判断文件传输

     print(str(data,"gbk"))

 s.close()

上述的代码实现了client端发送cmd指令到serve端进行执行后返回给client端结果的一个过程。

attention：一发一收

socket创建

　　s = socket.socket()这样就创建了一个socket对象。在serve端和client端分别需要创建一个。括号中仍有4个默认函数：

　　family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None

　　其中family是IPV4 的默认值，type是TCP的默认值。

设置值

　　创建好socket之后，serve端需要设置（4,5行）

　　1 bind绑定IP和端口。

　　2 listening值是最多等待。

　　3 接受client协议和地址即第八行

　　4 注意这里的conn就是client端的.socket 所以在接收的时候为conn.receive

　　client端只用设置连接的address和端口。

小细节

　　1.serve端的try是防止client端直接结束造成接收报错。

　　2.若接收的a为空表示client端主动断开了socket连接（本身发送不能发送空）。

关于subprocess

　　obj = subprocess.Popen(a.decode("utf8"),shell=True,stdout=subprocess.PIPE)
　　result = obj.stdout.read()

　　这两句话实现了cmd在子程序中运行后返回结果到result。

　　注意这里的result是gbk编码下的bytes类型。

关于这其中杂乱的编码

　　Python3中有两种格式：

　　　　str：str>>bytes 称为编码（encode）方法有1.re=bytes（“ccc”，“utf8”）2.re=“ccc”.encode（“utf8”）py3中str都是Unicode编码。兼容utf8，三字节表示中文。

　　　　bytes：bytes>>str称为解码（decode）方法有1.re = str（“ccc”，“utf8”）2.re=“ccc”.decode（“utf8”）bytes类型有相对应的编码协议。即什么样的编码形式　　（如utf8）就仍用什么样的解码。

　　Python2中也有两种：

　　　　str：即原来的3中的bytes

　　　　Unicode：即str u“你好” 表示内容用的Unicode编码。

　　pyhton3中页面用到utf8，2中用的阿斯克码。

大文件传输问题解决

　　发送端的sendall必将数据都发送过去，但是接收的时候一次最多接收设置值1024个字节。（received值最大8K）所以造成接收时显示缓慢。（接收第二条时仍旧显示第　　一条）

　　解决办法是：多次循环接收直到data大小等于文件大小。while len(data)!=result_len:不相等就继续接收。

2.socketserve

serve端

 import socketserver

 class Myserve(socketserver.BaseRequestHandler):

     def handle(self):

         print("active")

         while 1:

             conn = self.request

             print(self.client_address)

             while 1:

                 a = conn.recv(1024)

                 print(">>>", str(a, "utf8"))

                 if not a:

                     break

                 inp = input(">>>")

                 conn.send(bytes(inp, "utf8"))

             conn.close()

 mine = socketserver.ThreadingTCPServer(("127.0.0.1",8000),Myserve)

 mine.serve_forever()

上述通过调用socketserver实现了多个client和一个server进行通信的功能。

实现过程：

　　创建一个自己命名的server类myserver

　　只在此类中创建一个方法：handle名字不能变，逻辑按照功能设计

　　创建socketserver对象，调用ThreadingTCPServer方法传入address元组，和server。

　　serverforever（）激活这个并发的server。

巴特西

socketserve及其应用

1.cmd命令利用socket

socket创建

设置值

小细节

关于subprocess

关于这其中杂乱的编码

大文件传输问题解决

2.socketserve

最新文章

热门文章

巴特西

socketserve及其应用

1.cmd命令 利用socket

socket创建

设置值

小细节

关于subprocess

关于这其中杂乱的编码

大文件传输问题解决

2.socketserve

最新文章

热门文章

1.cmd命令利用socket