#服务端
import socket

ip_port = ("127.0.0.1", 8000)

back_log = 5

buffer_size = 1024

phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 参数分别为（基于网络通讯，TCP协议），表示基于TCP协议的网络通讯

phone.bind(ip_port)  # 参数为IP地址和端口号，以元组的形式放进参数里，且IP地址是字符串

phone.listen(back_log)  # 表示当前可以有几个链接

print("--->")

while True:        #设定循环，可以接收多个链接

    conn, addr = phone.accept( )  # 等待客户端信息，得到两个数据，一个是（对方的链接，一个是对方的通讯地址），元组形式

    while True:    #循环，服务端和客户端能循环多次的传输数据

        try:       #客户端断开链接时，服务端也会断开链接，这时循环时就会出现异常，需要处理异常

            data = conn.recv(buffer_size)  # 接收客户端信息，参数代表可以接收多少字节,得到的是二进制形式的数据

            print("接到客户端信息：", data.decode("utf-8"))

            conn.send(data.upper( ))  # 向客户端回传信息

        except Exception:

            break

    conn.close()

phone.close()

#客户端
import socket

ip_port = ("127.0.0.1",8000)

back_log = 5

buffer_size = 1024

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

phone.connect(ip_port)    #链接服务端

while True:

    msg = input(">>>")

    if not msg:continue          #输入为空时，可以send到自己的缓存中，但os不会将空发给硬件，对方便recv不到数据

    phone.send(msg.encode("utf-8"))       #向服务端传内容，传输的是二进制格式

    data = phone.recv(buffer_size)             #获取服务端传回的内容

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

phone.close()

from socket import *         #将socket下的所有属性都导入过来，这样可以直接使用属性

ip_port = ("127.0.0.1",8080)

buffer_size = 1024

udp_server = socket(AF_INET,SOCK_DGRAM)    #DGRAM表示数据报式套接字

udp_server.bind(ip_port)

while True:

    data,addr = udp_server.recvfrom(buffer_size)    #接收到客户端发过来是数据加客户端的IP和端口

    print(data,addr)

    udp_server.sendto(data.upper(),addr)   #无链接需要指定客户端的IP和端口

from socket import *

ip_port = ("127.0.0.1",8080)

buffer_size = 1024

udp_client = socket(AF_INET,SOCK_DGRAM)

while True:

    msg = input(">>")

    udp_client.sendto(msg.encode("utf-8"),ip_port)      #sendto需要指定发送到哪个IP和端口

    data,addr = udp_client.recvfrom(buffer_size)

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

udp_client.close()