python入行036(socket模块)

Posted mmmmmrz

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python入行036(socket模块)相关的知识,希望对你有一定的参考价值。

1 socket是什么

  socket是一个位于应用层和传输层之间的“抽象层”,他把复杂的tcp/ip协议族隐藏在socket接口后面。socket抽象层位于传输层上面, 用户无需深入理解tcp/udp协议,只需要遵循socket的规定去编程,写出的程序自然就是遵循tcp/udp标准的。

2 基于TCP的套接字

2.1 简单版

# 服务器端
import socket


s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建服务器套接字对象

s.bind((127.0.0.1, 8080))  # 绑定(ip, 端口号)到套接字对象

s.listen(5)  # 开始监听,5指的是半连接池的大小
print("服务器启动完成,开始监听")

conn, client_addr = s.accept()  # 被动接受客户端的连接,(阻塞式)等待连接的到来
print(client_addr)

data = conn.recv(1024)  # 接收TCP数据,最大接收的数据量为1024Bytes,收到的是bytes类型
print(data.decode(utf-8))

conn.send(hello.encode(utf-8))  # 发送TCP数据

conn.close()  # 关闭服务器套接字对象
# 客户端
import socket


c = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建客户端套接字对象

c.connect((127.0.0.1, 8080))  # 主动初始化服务器连接

c.send(hello, world.encode(utf-8))  # 发送TCP数据

data = c.recv(1024)  # 接收TCP数据
print(data.decode(utf-8))

c.close()  # 关闭客户端套接字对象

2.2 加上通信循环

# 服务器端
import socket


s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建服务器套接字对象

s.bind((127.0.0.1, 8080))  # 绑定(ip, 端口号)到套接字对象

s.listen(5)  # 开始监听,5指的是半连接池的大小
print("服务器启动完成,开始监听")

conn, client_addr = s.accept()  # 被动接受客户端的连接,(阻塞式)等待连接的到来

while True:
    try:
        data = conn.recv(1024)  # 接收TCP数据,最大接收的数据量为1024Bytes,收到的是bytes类型
        if not data:
            break
        print(客户端发送的消息, data.decode(utf-8))
        conn.send(hello.encode(utf-8))  # 发送TCP数据
    except Exception:
        break
conn.close()  # 关闭conn连接
# 客户端
import socket


c = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建客户端套接字对象

c.connect((127.0.0.1, 8080))  # 主动初始化服务器连接

while True:
    msg = input("输入要发送的消息>>>: ").strip()
    if not msg:
        continue
    c.send(msg.encode(utf-8))  # 发送TCP数据

    data = c.recv(1024)  # 接收TCP数据
    print(data.decode(utf-8))

c.close()  # 关闭客户端套接字对象

2.3 加上连接循环

# 服务器端
import socket


s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建服务器套接字对象

s.bind((127.0.0.1, 8080))  # 绑定(ip, 端口号)到套接字对象

s.listen(5)  # 开始监听,5指的是半连接池的大小
print("服务器启动完成,开始监听")

# 加上连接循环
while True:
    conn, client_addr = s.accept()  # 被动接受客户端的连接,(阻塞式)等待连接的到来

    while True:
        try:
            data = conn.recv(1024)  # 接收TCP数据,最大接收的数据量为1024Bytes,收到的是bytes类型
            if not data:
                break
            print(客户端发送的消息, data.decode(utf-8))
            conn.send(hello.encode(utf-8))  # 发送TCP数据
        except Exception:
            break
    conn.close()  # 关闭conn连接
# 客户端
import socket


c = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建客户端套接字对象

c.connect((127.0.0.1, 8080))  # 主动初始化服务器连接

while True:
    msg = input("输入要发送的消息>>>: ").strip()
    if not msg:
        continue
    c.send(msg.encode(utf-8))  # 发送TCP数据

    data = c.recv(1024)  # 接收TCP数据
    print(data.decode(utf-8))

c.close()  # 关闭客户端套接字对象

 3 基于UDP协议的套接字

# 服务器端
import socket

server=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # 数据报协议=》udp协议

server.bind((127.0.0.1,8081))

while True:
    data,client_addr=server.recvfrom(1024)
    server.sendto(data.upper(),client_addr)


server.close()
# 客户端
import socket

client=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # 流式协议=》tcp协议

while True:
    msg=input(>>>: ).strip()
    client.sendto(msg.encode(utf-8),(127.0.0.1,8081))
    res=client.recvfrom(1024)
    print(res)

client.close()

 

以上是关于python入行036(socket模块)的主要内容,如果未能解决你的问题,请参考以下文章

python入行022(常用模块介绍)

测试基础之集成测试(初入行)

Python中的socket模块

Python socket网络模块

python执行以下代码报:ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝,无法连接。

Python 之 socket网络模块简单应用