网站建设怎么做账务处理,创卫网站 建设 方案,聚财三个字公司名字,wordpress权限acl目录 写在开头 socket服务端#xff08;基础#xff09; socket客户端#xff08;基础#xff09; 服务端实现#xff08;可连接多个客户端#xff09; 客户端实现 数据收发效果 写在开头 近期可能会用python实现一些网络安全工具#xff0c;涉及到许多关于网络…目录 写在开头 socket服务端基础 socket客户端基础 服务端实现可连接多个客户端  客户端实现 数据收发效果 写在开头 近期可能会用python实现一些网络安全工具涉及到许多关于网络的知识逃不过的就是最基本的socket。本文将介绍如何通过python自带的socket库实现TCP客户端和服务端实现多个客户端与一个服务端的消息收发这是网络编程的基础。尽管python有许多第三方库可以创建网络客户端和服务端但其核心都是socket模块socket模块提供了许多有关网络连接的接口可以干很多事情后续我们还可能基于本文的案例慢慢继续开发实现一些主机扫描、数据包注入等工具。 socket套接字是进程之间进行网络通信的媒介通信时分为服务端和客户端可见下图图来自黑马程序员的python课件。 socket服务端被动等待其他进程客户端的连接可以同时连接多个客户端与之通信实现消息的收发。 socket客户端主动连接服务端与服务端通信。 下面我们先实现一个基础的服务端和客户端实现一个客户端与一个服务端之间的通信。 socket服务端基础 首先引入socket模块并创建socket服务端对象socket_server此时该对象还无法确定是客户端/服务端作为服务端应当绑定一个服务端的主机和端口这里就以本地localhost端口8888为例通过.bind方法传入元组。 import socket # 创建socket对象 socket_server socket.socket() # 绑定ip和端口表明是服务端 socket_server.bind((localhost, 8888)) 接下来通过listen方法让服务器开始监听传入一个int整数表示最大连接数。此处我们实现最基础的情况传入1仅允许一个客户端连接该服务端。接下来通过accept方法等待客户端的连接在此之前我们可以通过print打印提示“正在等待客户端连接”。accept方法是一个阻塞是的方法如果没有客户端连接程序将一直在这里等待连接。.accept()方法返回一个二元元组(conn, client_addr)conn表示客户端和服务端的连接对象client_addr (client_host, client_port)我们用两个变量conn和address分别接收 # listen方法内接受一个整数传参数表示接受的连接数量可不填 socket_server.listen(1) # 等待客户端连接accept方法返回二元元组(连接对象, 客户端地址信息) # accept()方法是阻塞式的方法如果没有客户端连接会一直等待不往下执行 print(f服务端已开始监听正在等待客户端连接...) conn, address socket_server.accept() print(f接收到了客户端的连接客户端的信息{address}}) 下面就可以实现数据的收发了数据的收发基于本次服务端与客户端的连接对象conn而非socket对象socket_server。这里假设客户端先发来消息服务端先接收客户端发来的消息再给客户端发送消息。接收消息使用recv方法该方法也是阻塞式只要没有接收到数据就会一直等待。其中的参数是缓冲区大小通常填1024即可recv接收到的消息返回值是字节流bytes对象因此还需要通过decode方法解码为字符串 data: str conn.recv(1024).decode(UTF-8) 接收完成后服务端通过send方法发送消息到客户端同样也需要将字符串编码为字节流的形式 msg input(请输入你要回复客户端的消息)conn.send(msg.encode(UTF-8)) # encode将字符串编码为字节数组对象 完善一下代码服务端实现持续的消息接收和发送直到服务端输入exit退出关闭服务端 while True:# 接收消息data: str conn.recv(1024).decode(UTF-8)print(f客户端发来的消息是{data})# 回复消息msg input(请输入你要回复客户端的消息)if msg exit:breakconn.send(msg.encode(UTF-8)) # encode将字符串编码为字节数组对象 最后关闭此次连接即可并关闭服务端。 conn.close() socket_server.close() 完整的服务端socket_server.py代码如下 import socketsocket_server socket.socket() socket_server.bind((localhost, 8888)) # 监听端口 socket_server.listen(1) # 等待客户端连接accept方法返回二元元组(连接对象, 客户端地址信息) print(f服务端已开始监听正在等待客户端连接...) conn, address socket_server.accept() print(f接收到了客户端的连接客户端的信息{address}})# 接受客户端信息使用客户端和服务端的本次连接对象而非socket_server while True:# 接收消息data: str conn.recv(1024).decode(UTF-8)print(f客户端发来的消息是{data})# 回复消息msg input(请输入你要回复客户端的消息)if msg exit:breakconn.send(msg.encode(UTF-8)) # encode将字符串编码为字节数组对象# 关闭连接 conn.close() socket_server.close() 写完了不要着急运行我们搞定客户端再一起试试。 socket客户端基础 客户端的代码和服务端差不多只不过客户端是主动连接服务器因此需要.connect方法连接服务器的host和端口传入元组(服务端主机, 服务端端口号)即可此处我们传入(localhost, 8888) import socket # 创建socket对象 socket_client socket.socket() # 连接到服务器 socket_client.connect((localhost, 8888)) 接下来实现数据的发送和接收此处客户端先发送消息给服务端再接收服务端回复的消息。同样的方法send方法发送recv方法接收注意Bytes字节流和字符串的转换即可 while True:send_msg input(请输入要发送给服务端的消息)if send_msg exit:break# 发送消息到服务端socket_client.send(send_msg.encode(UTF-8))# 接收服务端的消息recv_data socket_client.recv(1024).decode(UTF-8) # 1024是缓冲区大小一般就填1024 recv是阻塞式print(f服务端回复的消息是{recv_data}) 类似最后关闭连接 # 关闭连接 socket_client.close() 完整的客户端代码socket_client.py如下 import socket # 创建socket对象 socket_client socket.socket() # 连接到服务器 socket_client.connect((localhost, 8888))while True:send_msg input(请输入要发送给服务端的消息)if send_msg exit:break# 发送消息socket_client.send(send_msg.encode(UTF-8))# 接受消息recv_data socket_client.recv(1024).decode(UTF-8) # 1024是缓冲区大小一般就填1024 recv是阻塞式print(f服务端回复的消息是{recv_data})# 关闭连接 socket_client.close() 代码完成之后我们先运行服务端代码socket_server.py即可实现绑定服务器端口并等待客户端连接 然后开启客户端运行socket_client.py即可建立连接  此时回到刚才的服务端界面可以发现出现了提示建立了连接此次连接的客户端主机是本机127.0.0.1端口是2133 在客户端输入消息即可实现客户端到服务端的消息传送同理服务端也可以发送数据到客户端 任意一方输入exit即退出另一方再发消息由于连接已经关闭会出现异常 这样我们就实现了客户端与服务端的通信但此时只能有一个客户端连接到服务端如果想实现多个客户端就需要修改服务端listen()的参数允许更多的客户端连接下面进行讲解。 服务端实现可连接多个客户端  这里先直接给出完整的代码server.py import socket import threadingdef create_server_socket(host, port):socket_server socket.socket()socket_server.bind((host, port))socket_server.listen(5)print(f服务端已启动地址{host}端口{port})print(f正在等待客户端连接...)# 开启多线程收发来自多个客户端的数据num 0 # 标记客户端的编号while True:num 1conn, address socket_server.accept()print(f服务端已接受到客户端 {num}号 的连接请求客户端信息{address})client_handler threading.Thread(targethandle_client, args(conn, address, num))client_handler.start()# 处理收发数据 def handle_client(conn, address, num):while True:# 接收客户端发来的数据data_from_client: str conn.recv(1024).decode(UTF-8)print(f客户端 {num}号:{address}发来的消息是{data_from_client})# 发送消息到客户端msg input(f请输入你要回复客户端 {num}号:{address}的消息)if msg exit:breakconn.send(msg.encode(UTF-8)) # encode将字符串编码为字节数组对象conn.close()if __name__ __main__:server_host input(请输入服务端Host:)server_port int(input(请输入服务端port:))create_server_socket(server_host, server_port)其实也没有特别多的变化通过函数进行了封装然后修改listen方法传一个大于1的整数表示允许更多的客户端连接此处设置的最大连接数为5。将数据收发的过程封装在函数handle_client中额外设置了参数num表示这是第几个连接到该服务端的客户端。 当一个客户端成功建立连接的时候即运行完成conn, address socket_server.accept()之时将接收到的客户端socket对象保存在conn变量远程连接信息客户端host, 客户端port保存在address变量并启动线程指向handle_client函数传入连接对象conn连接信息address和客户端号num。创建好之后启动该线程。于此同时服务端create_server_socket中的while True循环也已经准备好处理下一个潜在的客户端连接。 客户端实现 客户端和刚才的其实可以没啥区别这里重新用函数封装为client1.py好了 import socketdef create_client(host, port):socket_client socket.socket()socket_client.connect((host, port))# 发送、接受数据while True:msg input(f请输入客户端1发送给服务端{host}:{port}的数据)if msg exit:break# 发送数据到服务端socket_client.send(msg.encode(UTF-8))# 接收服务端的数据data_from_server socket_client.recv(1024).decode(UTF-8)print(f客户端接收到服务端的消息{data_from_server})socket_client.close()if __name__ __main__:server_host input(请输入想要连接的服务端Host:)server_port int(input(请输入想要连接的服务端port:))create_client(server_host, server_port)由于要实现多个客户端的连接我们可以创建另外一个文件client2.py代码和client1一样。这里我就用刚才的socket_client.py做示范好了。 数据收发效果 首先运行服务端代码server.py。输入服务端的host本地localhost和port8888此时服务端就进入了等待客户端连接的状态 再运行客户端代码client1.py和socket_client.py 输入服务端的host和端口即可建立连接 服务端显示连接建立成功两个连接均已建立 然后两个连接即可各自实现服务端与客户端的数据收发注意都是客户端先发送消息服务端先接收消息。客户端1号client.py如下 客户端2号socket_server.py运行交互过程如下 服务端server.py的运行交互过程如下 任何一端输入exit即可退出对应的客户端和服务端建立的连接会断开其他的连接依旧正常通信比如这里服务端断开与client1的连接与客户端2 socket_client的通信不受影响 client1客户端1由于服务端已经端口异常退出了 客户端2不受影响 到这里就实现了多个客户端与服务端的消息传送。当然本文没有考虑如何处理阻塞、如何进行异常处理等细枝末节。后续可能会继续改进并基于socket基本的通信不断扩展其功能实现一些简易的网络工具。近期感觉网安就业困难以后可能还会更新一些大数据相关的内容敬请期待。如果读者有什么问题也欢迎评论区指出知无不言。总结不易还请读者多多点赞关注支持。