zoukankan      html  css  js  c++  java
  • socket

     1 import socket
     2 sk = socket. socket()
     3 address = ('127.0.0.1',8000)
     4 sk. bind( address)
     5 sk. listen(3)#设置等待的client数量
     6 conn, addr = sk.accept()#获得连接对象,和它的地址
     7 while True:
     8      date = conn. recv(1024)
     9       if not date:    #当client端退出后传过来的数据为空,client发送空,sever端不能接收,会处于阻塞状态
    10             conn.close()
    11             conn,addr = sk.accept()
    12             continue
    13      print( str( date,'utf8'))
    14      inp = input(">>>:")
    15      conn. send( bytes( inp))
    16 sk.close ()    
     1 import socket
     2 sk = socket.socket()
     3 addr = ('127.0.0.1',8000)
     4 sk.connent(addr)
     5 while True:
     6      inp = input("输入内容")
     7      if inp=='exit':
     8            break
     9      sk.send(bytes(inp))  #发送的内容与接受的内容都是bytes类型
    10      
    11      dete = sk.recv(1024)
    12      print(str(date,'utf8'))
    13      
    14 sk.close()

    命令的读取:

    import  subprogress
    a=subprogress.Popen("dir",shell=True,stdout=subprogress.PIPE)//
    print(a.stdout.read())

    将命令执行后转换过去

    粘包现象

     1 import socket
     2 import subprogress
     3 addr=('172.0.0.1',8400)
     4 sk=socket.socket() 6 sk. bind(addr)
     7 sk.listen()
     8 conn,addrs=sk.accept()
     9 while True:
    10      date= conn.recv()
    11      date=subprogress.Popen(str(date,'utf8'),sell=True,stdout=subprogress.PIPE)

     1  import socket
     2  import subprogress
     3  addr=('172.0.0.1',8400)
     4  sk=socket.socket()
     5  sk. bind(addr)
     6  sk.listen(3)
     7  conn,addrs=sk.accept()
     8  while True:
     9       date= conn.recv()
    10      date=subprogress.Popen(str(date,'utf8'),sell=True,stdout=subprogress.PIPE)
    11      r_date=stdout.read()
    12      len=len(r_date)
    13      conn.sendall(str(len))
    14      conn.recv(1024)//防止粘包
    15      
    16      
    17      conn.sendall(date)
    18      conn.close()
    19 sk.close()
     1  import socket
     2  sk = socket.socket()
     3  addr = ('127.0.0.1',8000)
     4  sk.connent(addr)
     5  while True:
     6        inp = input("输入内容")
     7        if inp=='exit':
     8             break
     9         sk.send(bytes(inp))  #发送的内容与接受的内容都是bytes类型
    10        len = sk.recv(1024)
    11        leng=0
    12       date=bytrs()//用来盛放接受的数据
    13       while leng!=int(str(len,'utf8'))
    14 
    15             date+= sk.recv(1024)
    16             
    17             leng +=int(len(str(date,'utf8')))
    18       print(str(date,'utf8'))
    19      
    20  sk.close()

     文件的上传与下载:

     1 import os
     2 import socket
     3 sk=socket.socket()
     4 addr=('127.0.0.1',8000)
     5 sk.connect(addr)
     6 
     7 base_dir=os.path.dirname(os.path.abspath(__file__))
     8 
     9 while True:
    10       inp=input('>>>:').strip()#post| 11.png
    11       cmd,path=inp.split("|")
    12       path=os.path.join(base_dir,path)
    13       fliename=os.path.basename(path)
    14       flie_size=os.stat(path).st_size#获取文件的长度,数据在bytes时的长度
    15       info="%s|%s|%s|%s".%(cmd,path,filename,file_size)
    16       sk.sendall(bytes(info,'utf8'))
    17        
    18 
    19       f=open(path,"rb")
    20       has_send=0
    21       while has_send!=file_size:
    22              date=f.read(1024)#可以指定读取数据的大小
    23              sk.sendall(date)
    24              has_send+=len(date)#获取bytes类型时的长度
    25        f.close()
    26 sk.close()
    27             
    28        
    29       
    30       
    31
     1 import os
     2 import socket
     3 sk=socket.socket()
     4 addr=('127.0.0.1',8000)
     5 sk.bind(addr)
     6 sk.listen(3)
     7 conn,add=sk.accept()
     8 
     9 
    10 base_dir=os.path.dirname(os.path.abspath(__file__))
    11 whiile 1:
    12       info=conn.recv(1024)
    13       cmd,filename,file_size=info.split("|")
    14       path=os.path.join(base_dir,filename)
    15      
    16       f=open(path,"ab")
    17       has_recv=0
    18       while has_recv!=int(str(file_size,"utf8")):
    19              date=conn.recv(1024)
    20              f.write(date)
    21              has_recv+=len(date)
    22       f.close()
    23       conn.close()

     socket类中方法总结:

    sk=socket.socket()//其中的两个参数family:AF_INET()  IPV4   AF_INET(6)  IPV

                                                                                 AF_UNIX  是UNIX系统下的协议

                                             type:SOCK_STREAM  tcp协议     SOCK_DGRAM udp协议

    sk.bind(addr)//绑定端口和IP地址

    sk.listen( number)//可以等待的数量

    sk.accept()//等待client连接并返回client对象,和client的地址

    sk.sendall()        sk.recv(大小)  

    sk.setblocking(bool )//设置是否堵塞(默认True)当设为False如果accept()或recv一旦无数据则报错

    sk.close()

    socketsever:

     1 import socketsever
     2 
     3 class Mysever(socketsever.BaseRequestHander):
     4      def handle(self)://此方法名不能更改,是重载了父类的方法,是逻辑算法的实现
     5           print("sever开始启动,,,”)
     6           while True:
     7               conn=self.request
     8               print(self.client_address)
     9               while True:
    10                    client_date=conn.recv(1024)
    11                    print(str(client_date,'utf8'))
    12                    sever_response=input(">>:")
    13                    conn.sendall(bytes(sever_response,'utf8'))
    14            conn.close()
    15 if __name__='__main__'
    16       sever = socketsever.ThreadingTCPSever(('127.0.0.1,8009'),Mysever)//实例化对象,
    17       sever.sever_forever()//执行主逻辑,此函数名不能改变。
  • 相关阅读:
    VS2013
    有了门面,程序会更加体面!- pos软件基于三层架构 -09
    无熟人难办事?- 闲聊设计模式-迪米特法则
    三层架构,分层开发
    Filezilla 错误
    归档和压缩
    在Linux系统下用dd命令制作ISO镜像U盘启动盘
    脚本语言
    node.js知识点提取
    npm cnpm
  • 原文地址:https://www.cnblogs.com/gjx1212/p/11785142.html
Copyright © 2011-2022 走看看