Python_Day33_网络编程Socket模块1详解编程语言

例：tcp协议聊天（一对一）-server端代码 
import socket 
from socket import SOL_SOCKET, SO_REUSEADDR 
''' 
实例化一个socket模块中的socket类的对象，为便于区别，在服务端我起名server 
可比喻为买手机 
''' 
server = socket.socket() 
''' 
此socket配置要在bind之前，用处是表示重用ip和端口, 
防止上次异常退出后再启动报地址在使用或端口被占用之类的错误 
可比喻为实名认证后下面的手机号码就属于你的了 
''' 
server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) 
''' 
表示服务端捆绑的ip地址与端口，在这里为本机测试故填回环地址127.0.0.1, 
端口是int类型的可用端口范围内的数字, 
可比喻为买手机卡. 
''' 
server.bind(('127.0.0.1', 9527)) 
# 表示开启侦听 
server.listen() #　可比喻为手机开机，能接收到信号了 
# 同意接收客户端链接，并将客户端的链接信息赋给两个变量 
conn, addr = server.accept() 
# 好奇的话可以print打印看看分别是什么 
print(conn) 
''' 
拿到的是类似这样的，链接过来的客户端信息: 
<socket.socket fd=300, family=AddressFamily.AF_INET,  
type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 9527),  
raddr=('127.0.0.1', 61463)> 
''' 
print(addr) 
# 拿到的是一个元组,里面包含有客户端ip和端口('127.0.0.1', 61463) 
# 做成循环模式，以便不断交互对话 
print('这里是服务端') 
while 1: 
# 接收客户端发送过来的字节信息 
ret = conn.recv(1024) 
# 如果客户端发送q/Q过来，表示退出聊天 
if ret.upper == 'Q': break 
# 打印并解码显示出来 
print(ret.decode('utf-8')) 
# 服务端这边也做成可以输入反馈开始尬聊，一人一句 
res = input('>>>').strip() 
# send方法代表发送消息过去客户端，需要转码 
conn.send(res.encode('utf-8')) 
# 自己这方也可以发送中止信号 
if res.upper() == 'Q':break 
conn.close() 
server.close() 
tcp协议聊天（一对一）- client端代码 
import socket 
client = socket.socket() 
ip = input('输入服务端ip:') 
port = input('输入端口:') 
# 通过ip和端口连接服务端 
client.connect((ip, int(port))) 
print('这里是客户端') 
while 1: 
res = input('>>>').strip() 
# 客户端传送消息给服务端 
client.send(res.encode('utf-8')) 
if res.upper() == 'Q': 
break 
# 客户端接收服务端传过来的消息 
ret = client.recv(1024) 
if ret.upper() == 'Q': 
break 
print(ret.decode('utf-8')) 
client.close() 
基于UDP协议的socket 
udp不是基于连接的，启动服务之后可以直接接受消息，不需要提前建立连接。 
udp协议-服务端代码： 
import socket 
from socket import SOL_SOCKET, SO_REUSEADDR 
# 实例化socket对象,type=socket.SOCK_DGRAM表示协议为udp 
udp_server = socket.socket(type=socket.SOCK_DGRAM) 
udp_server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) 
ip = input('请输入服务端侦听ip:').strip() 
port = input('请输入服务端侦听端口:').strip() 
udp_server.bind((ip, int(port))) 
print('这里是服务端') 
# udp 并不需要像tcp的connect先行连接 
while 1: 
# 和tcp不同，udp的接收方法是recvfrom 
msg, addr = udp_server.recvfrom(1024) 
if msg.upper == 'Q': 
break 
print(addr, msg.decode('utf-8')) 
res = input('>>>').strip() 
# 同样不同的是tcp发送是send，udp是sendto 
udp_server.sendto(res.encode('utf-8'), addr) 
if res.upper() == 'Q': 
break 
udp_server.close() 
udp协议，client端代码： 
import socket 
ip = input('输入服务端ip:') 
port = input('输入端口:') 
addr =(ip, int(port)) 
udp_client = socket.socket(type=socket.SOCK_DGRAM) 
print('这里是客户端') 
while 1: 
res = input('>>>').strip() 
udp_client.sendto(res.encode('utf-8'), addr) 
if res.upper() == 'Q': 
break 
back_msg = udp_client.recvfrom(1024)[0] 
if back_msg.upper() == 'Q': 
break 
print(back_msg.decode('utf-8'), addr) 
udp_client.close() 
例：时间同步服务器（伪） 
udp server端： 
#!/usr/bin/env python 
# _*_ coding: utf-8 _*_ 
# 时间同步服务 udp协议完成的 
# N台机器 
# 例如 00:00 从数据库里 读取一些数据 在一个机房里 有一台标准时间的服务器 
# 机房里所有的机器 都每隔一段时间 就去请求这台服务器 来获取一个标准时间 
import time 
import socket 
from socket import SOL_SOCKET, SO_REUSEADDR 
server = socket.socket(type=socket.SOCK_DGRAM) 
server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) 
server.bind(('127.0.0.1', 9527)) 
while 1: 
# 接收一个时间格式的消息 
msg, addr = server.recvfrom(1024) 
if not msg: 
# 默认的时间格式 
time_fmt = '%Y-%m-%d %X' 
else: 
time_fmt = msg.decode('utf-8') 
# 服务端发送标准时间到客户端 
server.sendto(time.strftime(time_fmt).encode('utf-8'), addr) 
server.close() 
udp client端： 
import time 
import socket 
ser =('127.0.0.1', 9527) 
client = socket.socket(type=socket.SOCK_DGRAM) 
client.sendto('%Y/%m/%d %H:%M:%S'.encode('utf-8'), ser) 
ret, addr = client.recvfrom(1024) 
print(ret.decode('utf-8')) 
client.close()