网络（socket）编程

1 import socket
2 phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
3 # 1.服务端套接字函数
4 phone.bind(‘主机ip地址‘,端口号)  #绑定到（主机，端口号）套接字
5 phone.listen() #开始TCP监听
6 phone.accept() #被动接受TCP客户的连接，等待连接的到来

1 2.客户端套接字函数
2 import socket
3 phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#买手机
4 phone.connect()  #主动连接服务端的ip和端口
5 phone.connect_ex()  #connect()函数的扩展版本，出错的时候返回错码，而不是抛出异常

1 3.服务端和客户端的公共用途的嵌套字函数
2 phone.recv() #接受TCP数据
3 phone.send() #发送TCP数据
4 phone.recvfrom() #接受UDP数据
5 phone.sendto() #发送UDP数据
6 phone.getpeername() #接收到当前套接字远端的地址
7 phone.getsockname() #返回指定套接字的参数
8 phone.setsockopt() #设置指定套接字的参数
9 phone.close() #关闭套接字

1 面向锁的套接字方法
2 phone.setblocking()  #设置套接字的阻塞与非阻塞模式
3 phone.settimeout()  #设置阻塞套接字操作的超时时间
4 phone.gettimeout()  #得到阻塞套接字操作的超时时间

1 面向文件的套接字函数
2 phone.fileno()  # 套接字的文件描述符
3 phone.makefile() #创建一个与该套接字相关的文件

 1 import socket
 2 phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#买手机
 3 phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #可以多次启动
 4 #执行多次的时候会报错，那么怎么办呢、？就在绑卡前面加上上面那句setsockopt方法就ok了
 5 phone.bind((‘192.168.20.44‘,8080))#绑定手机卡(ip,端口)
 6 # 端口号在1024以前的是系统用的，1024以后的都是你自己写的程序去定义的端口
 7 
 8 print(‘starting run......‘)
 9 phone.listen(5) #开机   5代表的是最多挂起5个，也可以好多个
10 while True: #链接循环
11     coon,client_addr=phone.accept()#等待接电话,（coon是建立的链接，客户端的ip和端口号组成的元组）
12     print(coon,client_addr)
13 
14     #收发消息
15     while True:  #通信循环
16         try:  #如果不加try...except ,就会报错，因为它不知道你什么时候断开链接的，服务器还以为你在运行
17             data = coon.recv(1024) #收了1024个字节的消息
18             print(‘client data 收到消息:%s‘%data.decode(‘utf-8‘))
19             coon.send(data.upper())  #发消息
20         except Exception:  #因为你不知道客户端什么时候断开链接，
21             break
22     coon.close() #挂电话
23 phone.close() #关机
24 
25 
26 # 处理逻辑错误的两种方式：
27     # if 判断
28     # try...except 异常处理
29 # 异常处理
30 # 当你知道直接错误的条件时就用if判断了
31 # 当程序错误一定发生，但是你又预知不了它出错的条件是什么的时候，就用try...except

 1 import socket
 2 phone = socket.socket(socket.AF_INET,socket.SOCK_STREAM)#买手机
 3 phone.connect((‘192.168.20.44‘,8080))  #直接连接服务端的ip和端口
 4 
 5 # 发收消息
 6 while True:
 7     msg = input(‘>>:‘).strip()  #用户输入
 8     if not msg:continue  #如果为空就继续输
 9     phone.send(msg.encode(‘utf-8‘))  #  发送你输入的消息
10     # phone.send(‘hello‘.encode(‘utf-8‘))
11     data = phone.recv(1024)  #在接收一下
12     print(‘server back res服务端返回结果:>>%s‘%data.decode(‘utf-8‘))
13 
14 phone.close()

 1 import socket
 2 import subprocess
 3 phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)#买手机
 4 phone.bind((‘192.168.20.44‘,8081))#绑定手机卡
 5 phone.listen(5)#阻塞的最大个数
 6 print(‘starting....‘)
 7 while True:
 8     conn,addr=phone.accept()#等待连接
 9     print(addr,conn)
10     while True:
11         cmd=conn.recv(10240)#接收的最大值
12         # if not cmd :break
13         print(‘接收的是：%s‘%cmd.decode(‘utf-8‘))
14         #处理过程
15         res=subprocess.Popen(cmd.decode(‘utf-8‘),shell=True,   #Popen是执行命令的方法
16                              stdout=subprocess.PIPE,
17                              stderr=subprocess.PIPE )
18         stdout=res.stdout.read()
19         stuerr=res.stderr.read()
20         conn.send(stdout+stuerr)
21     conn.close()
22 phone.close()

 1 import socket
 2 
 3 phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
 4 phone.connect((‘192.168.20.44‘,8081))#绑定端口
 5 while True:
 6     cmd=input(‘>>请输入‘).strip()
 7     if  not cmd: continue
 8     phone.send(cmd.encode(‘utf-8‘))
 9     data=phone.recv(10240)
10     print(‘返回的是%s‘%data.decode(‘gbk‘))
11 phone.close()