python的学习之路day7-socket网络编程

import socket

# 创建TCP/IP套接字：
tcpsocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 创建UDP/IP套接字：
udpsocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

from socket import * tcpsocket = socket(AF_INET, SOCK_STREAM)

# TCP时间戳服务器的伪代码
# import socket
# ss = socket.socket()          #创建服务器套接字
# ss.bind()                     #套接字与地址绑定
# ss.listen()                   #监听连接
# inf_loop:                     #服务器无限循环
#     cs = ss.accept()          #接收客户端连接
#     comm_loop:                #通信循环
#         cs.recv()/cs.send()   #对话（接收/发送）
#     cs.close()                #关闭客户端套接字
# ss.close()                    #关闭服务器套接字（可选）

import socket
import time  # 分别导入两个模块

HOST = ''  # 这是对bind()方法的标识，表示可以使用任何可用的地址
PORT = 1504  # 端口
BUFSIZ = 1024  # 设置缓存区大小
ADDR = (HOST, PORT)
tcp_ser_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_ser_sock.bind(ADDR)  # 将（地址、端口号）绑定到套接字在上
tcp_ser_sock.listen(5)
while True:  # 进入一个无限的循环
    print("waiting for connection...")  # 提示信息
    tcp_cli_sock, addr = tcp_ser_sock.accept()  # 被动的等待客户端连接
    print("...connected from: ", addr)  # 某个客户端已连接
    while True:  # 进入一个对话循环
        data = tcp_cli_sock.recv(BUFSIZ).decode()  # 接收TCP消息
        if not data:
            break  # 如果接收的消息为空，跳出当前循环，继续等待
        tcp_cli_sock.send(('[%s] %s' % (time.ctime(), data)).encode())  # 发送接收的消息，并且在前面加上当前时间
    tcp_cli_sock.close()  # 关闭客户端

# 伪代码
# import socket
# cs = socket.socket()    #创建客户端套接字
# cs.connect()            #尝试连接服务器
# comm_loop:              #通信循环
#     cs.send()/cs.recv() #对话（发送/接收）
# cs.close()              #关闭客户端套接字

import socket

HOST = 'localhost'
PORT = 1504
BUFSIZ = 1024
ADDR = (HOST, PORT)
tcp_cli_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_cli_sock.connect(ADDR)  # 主动发起TCP服务器连接

while True:
    data = input(">>>")
    if not data:  # 判断输入是否为空
        break
    tcp_cli_sock.send(data.encode())  # 发送输入的内容
    data = tcp_cli_sock.recv(BUFSIZ).decode()  # 接收返回的内容
    if not data:  # 判断返回的内容是否为空
        break
    print(data)  # 将返回的内容打印出来
tcp_cli_sock.close()  # 然后关闭连接

服务器：
waiting for connection...
...connected from:  ('127.0.0.1', 52064)
waiting for connection...

客户端：
>>>qwe
[Thu Jan 18 20:09:59 2018] qwe
>>>456
[Thu Jan 18 20:10:04 2018] 456
>>>

# 伪代码：
# ss = socket.socket()                  #创建服务器套接字
# ss.bind()                             #绑定服务器套接字
# inf_loop:                             #服务器无限循环
#     cs = cs.recvfrom()/ss.sendto()    #对话（接收/发送）
# ss.close()                            #关闭服务器套接字

import socket
import time  # 分别导入两个模块

HOST = ''  # 主机地址
PORT = 1504  # 端口号
BUFSIZ = 1024  # 缓存区大小
ADDR = (HOST, PORT)
udp_ser_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 使用udp协议
udp_ser_sock.bind(ADDR)  # 将地址和端口绑定到套接字上
# 可以看到没有listen，因为udp是无连接的，所以不用调用“监听传入连接”
while True:  # 进入一个无限循环
    print("waiting for massage...")  # 提示输出
    data, addr = udp_ser_sock.recvfrom(BUFSIZ)  # 接收UDP消息
    udp_ser_sock.sendto(("[%s] %s" % (time.ctime(), data.decode("utf-8"))).encode(), addr)  # 将接收到的消息加上时间发送给客户端
    print("...received from and returned to:", addr)  # 打印已发送给谁
udp_ser_sock.close()

# 伪代码
# cs = socket()                     #创建客户端套接字
# comm_loop:                        #通信循环
#     cs.sendto()/cs.recvfrom()     #对话（发送/接收）
# cs.close()                        #关闭客户端套接字

import socket

HOST = 'localhost'  # 地址
PORT = 1504  # 端口
BUFSIZ = 1024  # 缓存
ADDR = (HOST, PORT)
udp_cli_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)  # 使用udp协议
while True:  # 进入一个无限循环
    data = input(">>>")  # 输入
    if not data:  # 判断输入是否为空
        break
    udp_cli_sock.sendto(data.encode(), ADDR)  # 将输入的内容和本地的地址和端口发送到服务器
    data, ADDR = udp_cli_sock.recvfrom(BUFSIZ)  # 接收服务器传回来的内容
    if not data:
        break
    print(data.decode("utf-8"))  # 打印
udp_cli_sock.close()

服务器：
waiting for massage...
...received from and returned to: ('127.0.0.1', 64721)
waiting for massage...
...received from and returned to: ('127.0.0.1', 64722)
waiting for massage...


客户端：
>>>asd
[Fri Jan 19 14:21:47 2018] asd
>>>asd
[Fri Jan 19 14:21:51 2018] qwe

import socketserver
import time

HOST = ""
PORT = 1504
ADDR = (HOST, PORT)


class my_request_handler(socketserver.StreamRequestHandler):
    def handle(self):
        print("...connected from:", self.client_address)
        self.wfile.write('[%s] %s' % (time.ctime(), self.rfile.readline()))


tcp_serv = socketserver.TCPServer(ADDR, my_request_handler)
print("waiting for connection...")
tcp_serv.serve_forever()

import socket

HOST = "localhost"
PORT = 1504
BUFSIZ = 1024
ADDR = (HOST, PORT)
while True:
    tcp_cli_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    tcp_cli_sock.connect(ADDR)
    data = input(">>>")
    if not data:
        break
    tcp_cli_sock.send(data.encode())
    data = tcp_cli_sock.recv(BUFSIZ).decode()
    if not data:
        break
    print(data.strip())
    tcp_cli_sock.close()

服务器：
waiting for connection...
...connected from: ('127.0.0.1', 59956)

客户端：
>>>sdas
就这样一直卡着

如果像书上一样：
TypeError: a bytes-like object is required, not 'str'