socket编程

1. 什么是socket编程

socket编程简介：
    能够唯一标示网络中的进程后，它们就可以利用Socket进行通信了，什么是Socket呢？我们经常把Socket翻译为套接字，Socket是在应用层和传输层之间的一个抽象层，它把TCP/IP层复杂的操作抽象为几个简单的接口供应用层调用已实现进程在网络中通信

基于文件类型的套接字家族：
    # 套接字家族的名字：AF_UNIX

基于网络类型的套接字家族
    # 套接字家族的名字：AF_INET

2.  基于TCP协议的套接字(socket)编程

1. 客户端和服务端应该是谁先发消息、
    # 客户端先发消息 但是需要先启动服务端

2. 服务端代码
import socket
from socket import AF_INET

server = socket.socket(family=AF_INET,type=socket.SOCK_STREAM)

# 基于什么网络 接收或发送的 两种方式
# AF_INET, type=SOCK_STREAM: 基于TCP协议的
# AF_INET, type=SOCK_DGRAM: 基于UDP协议的

# 绑定IP地址和端口号
server.bind(('127.0.0.1',8000))

# 服务端监听 也称为半连接池 就是同时能接收但是用户的访问
server.listen(5)

# 接收用户发送过来的消息
while True:
        sock,addr = server.accept()
        """sock:当前链接的客户端的链接， addr:就是客户端的地址：ip，port"""
        while True:
            try:
                # 想拿到用户发送过来的数据
                data = sock.recv(1024)  # 接收的数据类型是bytes类型，二进制的 1024 代表接收的最多的字节数
                print("接收客户端的数据：",data)
                abc_str = 'love'
                # 要给用户返回的数据
                sock.send((data + b'love').upper()) # 返回的数据也必须是字节类型
            except Exception as e:
                print(e)
                break
        # 关闭客户连接
        sock.close()
# 关闭服务端连接
server.close()


3. 客户端代码
import socket

from socket import AF_INET

# 服务端是UDP协议 客户端的传输发送要一样
client = socket.socket(family=AF_INET,type=socket.SOCK_STREAM)

# 第一个是服务端的 IP地址，第二个是 端口号
client.connect(('127.0.0.1',8000))

# 开始给服务端发送消息
while True:
    cmd = input("输入发送的内容>>>:").strip()

    # 开始给服务端发送消息
    client.send(cmd.encode()) # 只能发送二进制

    # 接收服务端回复的消息
    data = client.recv(1024) # 代表回复的最大字节

    print("服务端发来的消息：", data)

# 关闭客户端
client.close()

3. 基于UDP协议的套接字编程

"""客户端"""
import socket

client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 数据报协议-》UDP

while True:
    msg = input('>>: ').strip()  # msg=''
    client.sendto(msg.encode('utf-8'), ('127.0.0.1', 8080))
    data, server_addr = client.recvfrom(1024)
    print(data)

client.close()

"""服务端"""
import socket

server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 数据报协议-》UDP
server.bind(('127.0.0.1', 8080))

while True:
    """client_addr: 客户端的地址"""
    data, client_addr = server.recvfrom(1024) # 接收的最大字节数
    print('===>', data, client_addr)
    server.sendto(data.upper(), client_addr)

server.close()