铁乐学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(‘这里是服务端‘)

while1:
    # 接收客户端发送过来的字节信息
    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(‘这里是客户端‘)
while1:
    res =input(‘>>>‘).strip()
    # 客户端传送消息给服务端
    client.send(res.encode(‘utf-8‘))
    if res.upper() ==‘Q‘:
        break# 客户端接收服务端传过来的消息
    ret = client.recv(1024)
    if ret.upper() ==‘Q‘:
        breakprint(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先行连接while1:
    # 和tcp不同，udp的接收方法是recvfrom
    msg, addr = udp_server.recvfrom(1024)
    if msg.upper ==‘Q‘:
        breakprint(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(‘这里是客户端‘)

while1:
    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‘:
        breakprint(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))

while1:
    # 接收一个时间格式的消息
    msg, addr = server.recvfrom(1024)
    ifnot 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()