网络基础复习02

# tcp
# server 
import socket
sk = socket.socket()  # 买手机  # 创建一个socket对象
sk.bind(("127.0.0.1",8081))  # 给server端绑定一个ip和端口
sk.listen()    # 括号里写数字，代表着允许几个人连接我
while True:
    conn,addr = sk.accept()   # 传过来的一定是一个元祖
                     # 这是获取到一个客户端的连接，已经完成了三次握手建立一个连接。
                     # 这时会阻塞
    while True:
        msg = conn.recv(1024).decode("utf-8")  # 阻塞 会一直停在这里
                                              # 直到收到一个客户端发来的消息
        print(msg)
        if msg == "bye":
            break
        info = input(">>>")
        if info == "bye":
            conn.send(b"bye")
            break
        conn.send(info.encode("utf-8"))  # 发信息
    conn.close()  # 关闭连接
sk.close()    # 关闭socket对象，如果不关闭，还能继续接收

# client

import socket
sk = socket.socket()
sk.connect(("127.0.0.1",8081))
while True:
    msg = input(">>>")
    if msg == "bye":
        sk.send(b"bye")
        break
    sk.send(msg.encode("utf-8"))
    ret = sk.recv(1024).decode("utf-8")
    if ret == "bye":
        break
    print(ret)
sk.close()

# client2

# import socket
# sk = socket.socket()
# sk.connect(("127.0.0.1",8081))
# while True:
#     msg = input("client2:>>>")
#     if msg == "bye":
#         sk.send(b"bye")
#         break
#     sk.send(("client2:" + msg).encode("utf-8"))
#     ret = sk.recv(1024).decode("utf-8")
#     if ret == "bye":
#         break
#     print(ret)
# sk.close()

# udp
# import socket
# sk = socket.socket(type=socket.SOCK_DGRAM)
# sk.bind(("127.0.0.1",8081))
#
# msg,addr = sk.recvfrom(1024)
# print(msg.decode("utf-8"))
# sk.sendto(b"bye",addr)
# sk.close()


# udp的server 不需要进行监听，也不需要建立连接
# 在启动服务之后只能被动的等待客户端发送消息过来
# 客户端发送消息的同时还会 自带地址信息
# 消息回复的时候 不仅需要发送消息，还需要把对方的地址在发送回去

# client

# import socket
# sk = socket.socket(type=socket.SOCK_DGRAM)
# ip_port = ("127.0.0.1",8081)
#
# sk.sendto(b"hello",ip_port)
# ret,addr = sk.recvfrom(1024)  # 没有链接，所以收发时都要带着地址
# print(ret.decode("utf-8"))
#
# sk.close()


# udp

import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind(("127.0.0.1",8080))
while True:
    msg,addr = sk.recvfrom(1024)
    print(addr)
    print(msg.decode("utf-8"))
    info = input(">>>").encode("utf-8")
    sk.sendto(info,addr)
sk.close()


import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
ip_port = ("127.0.0.1",8080)
while True:
    info = input("二哥：")
    info = ("33[32m来自二哥的消息：%s33[0m"%info).encode("utf-8")
    sk.sendto(info,ip_port)
    msg,addr = sk.recvfrom(1024)
    print(msg.decode("utf-8"))
sk.close()

#  client2

import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
ip_port = ("127.0.0.1",8080)
while True:
    info = input("tiger:")
    info = ("33[34m来自tiger的消息：%s33[0m"%info).encode("utf-8")
    sk.sendto(info,ip_port)
    msg,addr = sk.recvfrom(1024)
    print(msg.decode("utf-8"))

sk.close()

# 注：本文是根据老男孩课程内容整理而成的，本文仅供个人笔记使用，如果有侵犯，请联系我，我立即撤销。