import socket

client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

client.connect(("127.0.0.1",9999))

while True:

        data = input(">>>:")

        if not data:continue

        client.send(data.encode("utf-8"))

        msg = client.recv(1024).decode("utf-8")

        print(msg)

client.close()

import socket

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

server.bind(("127.0.0.1",9999))

#  不是最大连接数  !!

server.listen(5)

while True:

    c,addr = server.accept()

    while True:

        try:

            msg = c.recv(1024).decode("utf-8")

            if not msg:

                c.close()

                break

            c.send(msg.upper().encode("utf-8"))

        except BaseException:

            print("客户端异常断开")

            c.close()

            break

server.close()

import socket

# 创建socket对象  指定type参数为socket.SOCK_DGRAM 表示使用UDP协议

server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # datagram数据报的意思

# 绑定ip和端口

server.bind(("127.0.0.1",8888))

while True:

    # 接收数据 返回一个元祖  数据和 发送方的地址

    msg,c_addr = server.recvfrom(1024)

    print("收到来自%s: 说:%s" % (c_addr[0] ,msg.decode("utf-8")))

    # 发送数据到指定ip和端口

    server.sendto(msg.upper(),c_addr)

import socket

# 创建socket对象  指定type参数为socket.SOCK_DGRAM 表示使用UDP协议

server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # datagram数据报的意思

# 绑定ip和端口

server.bind(("127.0.0.1",8888))

while True:

    # 接收数据 返回一个元祖  数据和 发送方的地址

    msg,c_addr = server.recvfrom(1024)

    print("收到来自%s: 说:%s" % (c_addr[0] ,msg.decode("utf-8")))

    # 发送数据到指定ip和端口

    server.sendto(msg.upper(),c_addr)

import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

while True:

    msg = input(">>>:")

    c.sendto(msg.encode("utf-8"),("127.0.0.1",8848))

    msg, addr = c.recvfrom(1024)

    print(msg.decode("utf-8"))

import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

while True:

    msg = input(">>>:")

    c.sendto(msg.encode("utf-8"),("127.0.0.1",8848))

    msg, addr = c.recvfrom(1024)

    print(msg.decode("utf-8"))

"""

    群聊思路

        1.客户端先把数据交给服务器

        2.服务器先存储对方的地址

        3.把收到的数据给所有人都发一遍

"""

import socket

server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

server.bind(("127.0.0.1",8848))

# 如果客户端与服务器在同一台计算机  并且有多个客户端  这些客户端ip都是相同的127.0.01

clients = {}#定义个群聊客户字典

while True:

    msg,addr = server.recvfrom(1024)

    # 存储对方的地址:

    clients[addr[1]] = addr

    print(msg.decode("utf-8"))

    # 循环发给所有人

    for c in clients:

        # 这个消息不用给发送方发回去

        # if c == addr[1]:

        #     continue

        server.sendto(msg,clients[c])

import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

while True:

    msg = input(">>>:")

    c.sendto(msg.encode("utf-8"),("127.0.0.1",8848))

"""

    群聊思路

        1.客户端先把数据交给服务器

        2.服务器先存储对方的地址

        3.把收到的数据给所有人都发一遍

"""

import socket

server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

server.bind(("127.0.0.1",8848))

# 如果客户端与服务器在同一台计算机  并且有多个客户端  这些客户端ip都是相同的127.0.01

clients = {}

while True:

    msg,addr = server.recvfrom(1024)

    # 存储对方的地址:

    clients[addr[1]] = addr

    print(msg.decode("utf-8"))

    # 循环发给所有人

    for c in clients:

        # 这个消息不用给发送方发回去

        # if c == addr[1]:

        #     continue

        server.sendto(msg,clients[c])

import socket

c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# 先随便发一条消息给服务器  让服务知道自己的地址

c.sendto("register".encode("utf-8"),("127.0.0.1",8848))

while True:

    msg, addr = c.recvfrom(1024)

    print(msg.decode("utf-8"))

1.UDP 不会粘包
2.缓冲区大小要足够装数据包大小  建议不要超过512

UDP的使用场景: 视频电话 语音电话  直播

DNS  域名解析服务器

1.TCP模板代码
    半连接池的工作原理
    目前我们的程序是单线程 服务器要么处理通讯要么处理连接请求 无法同时进行

2.TCP 和 UDP 发送数据时的流程 *****
    解释 为何TCP是可靠的 是因为发送数据后必须收到确认包

3. UDP的模板代码 *****
    与TCP代码的区别
    不需要监听 不需要接收
    type参数为 SOCK_DGRAM
    UDP 可以同时处理多个客户端 是因为CPU处理速度快 给人感觉像是同时处理

 

"""
    TCP  可靠的传输
        TCP传输数据前需要三次握手建立连接

    UDP  不可靠传输
        直接发送数据包  不关心对方是否接收成功

"""