我们可以将网络编程分为2个模块:服务器编程和客服端编程,接下来的代码会告诉你这两个模块的相同之处以及不同之处。
服务器
from socket import socket, AF_INET, SOCK_STREAM
import time
import datetime
def main():
# 创建一个基于TCP协议的套接字对象
# 因为我们做的是应用级的产品或服务所以可以利用现有的传输服务来实现数据传输(TCP UDP)
server = socket(AF_INET, SOCK_STREAM) # 表达的是ipv4 和tcp协议(默认前面两个) 或者 udp协议
# 绑定IP地址(网络上的主机的身份标识)和端口(用来区分不同服务的IP地址的扩展)
server.bind(('127.0.0.1', 6789))
# 开始监听客户端的连接
server.listen(512)
print('服务器已经启动正在监听...')
time1 = str(datetime.datetime.now())
while True:
# 通过accept方法接收客户端的连接
# accept方法是一个阻塞式的方法 如果没有客户端连上来
# 那么accept方法就会让代码阻塞 知道客户端连接成功才返回
# accept方法返回一个元组 元祖宗的第一个值是代表客户端的对象
# 元组的第二个值又是一个元组 其中有客户端的IP地址和客户端的端口
client, addr = server.accept()
print(addr, '连接成功')
while True:
data = client.recv(512)
print(data.decode('utf-8'))
b = input('服务器:')
client.send(('服务器:' + b).encode('utf-8'))
# client.send(time1.encode('utf-8'))
# client.close()
if __name__ == '__main__':
main()
客户端
from socket import socket
def main():
# 表示持久化连接
while True:
# 创建套接字 其实就是创建一个通信口
client = socket()
# 客户端是连接ip地址和端口号 服务器端则是绑定(bind)ip地址和端口号
client.connect(('127.0.0.1', 6789))
while True:
# 进行通信
a = input('客户端:')
client.send(('客户端:' + a).encode('utf-8'))
data = client.recv(512)
# print(type(data))
print(data.decode('utf-8'))
if __name__ == '__main__':
main()