Python升级之路( Lv16 ) 网络编程

socket.socket([family[, type[, proto]]])

udpSocket=socket.socket (AF_INET,SOCK_DGRAM)

from socket import *

"""UDP接收数据"""
# 1. 创建套接字
s = socket(AF_INET, SOCK_DGRAM)
# 2. 绑定端口(传入1个元组)
s.bind(("127.0.0.1", 8848))
print("等待接收数据:")
# 3. 接收数据, 1024为当前最大传输字节
rspData = s.recvfrom(1024)
print(rspData)
print(f'收到远程的消息: {rspData[0].decode("utf-8")}, from{rspData[1]}')
# 4. 关闭连接
s.close()

from socket import *

"""udp发送数据"""
# 1. 创建套接字
s = socket(AF_INET, SOCK_DGRAM)
# 2. 绑定端口(发送时绑定的, 是接收的端口)
addr = ("127.0.0.1", 8848)
data = input("请输入:")
# 3. 发送数据
s.sendto(data.encode("utf-8"), addr)
# 4. 关闭连接
s.close()

from socket import *

"""持续通信: UDP接收数据"""
# 1. 创建套接字
s = socket(AF_INET, SOCK_DGRAM)
# 2. 绑定端口(传入1个元组)
s.bind(("127.0.0.1", 8848))
print("等待接收数据:")
while True:
    # 3. 接收数据, 1024为当前最大传输字节
    rspData = s.recvfrom(1024)
    rspContent = rspData[0].decode("utf-8")
    print(f'收到远程的消息: {rspContent}')
    if rspContent == "88":
        print("结束聊天! ")
        break
# 4. 关闭连接
s.close()

from socket import *

"""持续通信: udp发送数据"""
# 1. 创建套接字
s = socket(AF_INET, SOCK_DGRAM)
# 2. 绑定端口(发送时绑定的, 是接收的端口)
addr = ("127.0.0.1", 8848)

while True:
    data = input("请输入:")
    # 3. 发送数据
    s.sendto(data.encode("utf-8"), addr)
    if data == "88":
        print("结束聊天！")
        break
# 4. 关闭连接
s.close()

from socket import *
from threading import Thread

# 不停接收
def recv_data():
    while True:
        # 3. 接收数据, 1024为当前最大传输字节
        rspData = s.recvfrom(1024)
        rspContent = rspData[0].decode("utf-8")
        print(f'服务端收到远程的消息: {rspContent}')
        if rspContent == "88":
            print("客户端请求结束聊天! ")
            break

# 不停发送
def send_data():
    addr = ("127.0.0.1", 7777)
    while True:
        data = input(">")
        s.sendto(data.encode("utf-8"), addr)
        if data == "88":
            break

if __name__ == '__main__':
    """多线程实现: UDP实现多线程服务端"""
    # 1. 创建套接字
    s = socket(AF_INET, SOCK_DGRAM)
    # 2. 绑定端口(传入1个元组)
    s.bind(("127.0.0.1", 9999))
    print("等待接收数据:")
    # 创建两个线程
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()

from socket import *
from threading import Thread

# 不停接收
def recv_data():
    while True:
        # 3. 接收数据, 1024为当前最大传输字节
        rspData = s.recvfrom(1024)
        rspContent = rspData[0].decode("utf-8")
        print(f'客户端收到远程的消息: {rspContent}')
        if rspContent == "88":
            print("服务端请求结束聊天! ")
            break


# 不停发送
def send_data():
    while True:
        data = input(">")
        addr = ("127.0.0.1", 9999)
        s.sendto(data.encode("utf-8"), addr)
        if data == "88":
            break


if __name__ == '__main__':
    """多线程实现: UDP实现多线程客户端"""
    # 1. 创建套接字
    s = socket(AF_INET, SOCK_DGRAM)
    # 2. 绑定端口(传入1个元组)
    s.bind(("127.0.0.1", 7777))
    # 创建两个线程
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()

from socket import *

"""TCP服务器端接收数据"""
# 1. 创建Socket对象(TCP)
tcp = socket(AF_INET, SOCK_STREAM)
# 2. 绑定端口号
tcp.bind(("127.0.0.1", 8979))
# 3. 监听端口号
tcp.listen(5)
# 4. 等待socket连接
"""
client 表示这个新的客户端
client_info 表示这个新的客户端的ip以及port
"""
client, client_info = tcp.accept()
# 5. 读取数据
recv_data = client.recv(1024)
print(f"收到信息:{recv_data.decode('utf-8')},来自:{client_info}")
# 6. 关闭连接
client.close()
tcp.close()

from socket import *

"""TCP客户端发送数据到服务端"""
# 1. 创建Socket对象(TCP)
tcp = socket(AF_INET, SOCK_STREAM)
# 2. 连接端口号(和接收略微不同)
tcp.connect(("127.0.0.1", 8979))
"""
注意：
 1. tcp客户端已经链接好了服务器，所以在以后的数据发送中，不需要填写对方的ip和port----->打电话
 2. udp在发送数据的时候，因为没有之前的链接，所以需要在每次的发送中，都要填写接收方的ip和port－－－－－＞写信　
"""
# 3. 等待socket连接
tcp.send("客户端发送消息".encode("utf-8"))
# 4. 关闭连接
tcp.close()

from socket import *

"""TCP服务器端接收数据"""
# 1. 创建Socket对象(TCP)
tcp = socket(AF_INET, SOCK_STREAM)
# 2. 绑定端口号
tcp.bind(("127.0.0.1", 8979))
# 3. 监听端口号
tcp.listen(5)
# 4. 等待socket连接
"""
client 表示这个新的客户端
client_info 表示这个新的客户端的ip以及port
"""
client, client_info = tcp.accept()
print("一个客户端建立连接成功! ")
while True:
    # 5. 读取数据
    recv_data = client.recv(1024).decode("utf-8")
    print(f"收到信息:{recv_data},来自:{client_info}")
    if recv_data == "88":
        break
    # 获取控制台信息
    msg = input('>')
    # tcp连接成功后, 发送或接收的使用的不是一个对象!!!
    client.send(msg.encode("utf-8"))

# 6. 关闭连接
client.close()
tcp.close()

from socket import *

"""
双向通信Socket之客户端

将控制台输入的信息发送给服务器端
读取服务器端的数据，将内容输出到控制台
"""
# 1. 创建Socket对象(TCP)
tcp = socket(AF_INET, SOCK_STREAM)
# 2. 连接端口号
tcp.connect(("127.0.0.1", 8979))
# 3. 发送和接收数据
while True:
    # 获取控制台信息
    msg = input('>')
    tcp.send(msg.encode("utf-8"))
    if msg == "88":
        break
    # 接收服务器端数据
    rsp_data = tcp.recv(1024).decode("utf-8")
    print("服务端回复:", rsp_data)
# 4. 关闭连接
tcp.close()

from socket import *
from threading import Thread

"""TCP服务器端接收数据"""
# 1. 创建Socket对象(TCP)
tcp = socket(AF_INET, SOCK_STREAM)
# 2. 绑定端口号
tcp.bind(("127.0.0.1", 8979))
# 3. 监听端口号
tcp.listen(5)
# 4. 等待socket连接
"""
client 表示这个新的客户端
client_info 表示这个新的客户端的ip以及port
"""
client, client_info = tcp.accept()
print("一个客户端建立连接成功! ")


def recv_data():
    while True:
        # 5. 读取数据
        recv_data = client.recv(1024).decode("utf-8")
        print(f"服务端收到信息:{recv_data},来自:{client_info}")
        if recv_data == "88":
            break


def send_data():
    while True:
        # 获取控制台信息
        msg = input('>')
        # tcp连接成功后, 发送或接收的使用的不是一个对象!!!
        client.send(msg.encode("utf-8"))
        if msg == "88":
            print("服务端结束聊天")
            break


if __name__ == "__main__":
    t1 = Thread(target=recv_data)
    t2 = Thread(target=send_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    # 6. 关闭连接
    client.close()
    tcp.close()

from socket import *
from threading import Thread

"""
双向通信Socket之客户端

将控制台输入的信息发送给服务器端
读取服务器端的数据，将内容输出到控制台
"""
# 1. 创建Socket对象(TCP)
tcp = socket(AF_INET, SOCK_STREAM)
# 2. 连接端口号
tcp.connect(("127.0.0.1", 8979))


# 3. 发送和接收数据
def send_data():
    while True:
        # 获取控制台信息
        msg = input('>')
        tcp.send(msg.encode("utf-8"))
        if msg == "88":
            print("客户端结束聊天")
            break


def recv_data():
    while True:
        # 接收服务器端数据
        rsp_data = tcp.recv(1024).decode("utf-8")
        print("服务端回复:", rsp_data)
        if rsp_data == "88":
            break


if __name__ == "__main__":
    t1 = Thread(target=send_data)
    t2 = Thread(target=recv_data)
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    # 4. 关闭连接
    tcp.close()