Python Socket网络编程入门:创建服务端与客户端通信
本文介绍Python中基于Socket的网络编程基础。详细解析socket()函数的family、type及protocol参数,并通过Python 3.6.2环境下的完整代码示例,演示如何构建具备自动应答与命令执行功能的服务端及客户端,实现主机间进程通信。
Python提供了两个层级的网络服务访问方式。
较低层级的网络服务支持基础的Socket,它提供了标准的BSD Sockets API,允许访问底层操作系统Socket接口的全部方法。较高级别的网络服务模块SocketServer则提供了服务器中心类,旨在简化网络服务器的开发过程。
什么是Socket?
Socket通常被称为“套接字”,应用程序一般通过套接字向网络发出请求或对网络请求做出响应,从而实现主机之间或同一台计算机上不同进程之间的通信。
socket()函数
在Python中,我们使用socket()函数来创建套接字,其语法格式如下:
socket.socket([family[, type[, proto]]])
参数说明
family:套接字家族可以是AF_UNIX或者AF_INET。type:套接字类型根据是否面向连接,可分为SOCK_STREAM或SOCK_DGRAM。protocol:通常不填写,默认值为0。
接下来通过Socket实现服务端与客户端的简单通信,模拟SSH的部分功能以及自动应答机制。
以下是服务端程序的简单示例:
#!/usr/bin/env python
#coding:utf-8
'''
file:server.py
date:9/8/17 3:43 PM
author:lockey
email:lockey@123.com
desc:socket编程服务器端,python3.6.2
'''
import re
import socket,time,os
s = socket.socket() # 创建 socket 对象
host = '127.0.0.1'#socket.gethostname() # 获取本地主机名
port = 9999 # 设置端口
s.bind((host, port)) # 绑定端口
s.listen(5) # 等待客户端连接
while True:
conn, addr = s.accept() # 建立客户端连接。
print('conneted address:'.decode('utf-8'), addr)#显示连接到服务器的客户端的地址
while True:
data = conn.recv(1024)
#接收到的客户端的请求或者返回
if not data:
#当返回信息为空或者请求为空时断开客户端连接
print('Connection closed!')
break;
data = data.decode('utf-8')
#以下前三个条件都是设置的自动检测应答,最后一个是根据输入的内容进行的命令执行,并将结果返回给客户端
if re.findall(r'who',data):
reply = 'I am lockey'.encode('utf-8')
elif re.findall(r'gender',data):
reply = 'A boy'.encode('utf-8')
elif re.findall(r'age',data):
reply = '23'.encode('utf-8')
else:
print('execute com:',data)
cmd_res = os.popen(data).read()
if not cmd_res:
#对于命令的执行如果没有返回值的话就给客户端发送一条信息
conn.send('No response'.encode('utf-8'))
continue
reply = cmd_res.encode('utf-8')
conn.send(reply)
#将结果发送给客户端
客户端程序的简单实现如下:
#!/usr/bin/env python
#coding:utf-8
'''
file:client.py
date:9/8/17 3:43 PM
author:lockey
email:lockey@123.com
desc:socket编程客户端,python3.6.2
'''
import socket,time # 导入 socket 模块
s = socket.socket() # 创建 socket 对象
host = '127.0.0.1'#socket.gethostname() # 获取本地主机名
port = 9999 # 设置端口好
s.connect((host, port))
while True:
cmd = input("lockey#")
#用户输入
if len(cmd) == 0:continue
#如果用户未输入内容则继续下一次输入
s.send(cmd.encode('utf-8'))
#将用户输入的内容发送给客户端等待结果
result = s.recv(1024)
if not result:
#如果服务端没有返回结果则继续下一次输入
continue
print(result.decode('utf-8'))
#如果服务端有返回则打印结果
s.close()
#用户终止程序时关闭连接
服务器端运行结果展示

客户端运行截图展示

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持本站。
本站声明
本文内容仅供参考,不代表本站观点。转载或引用请注明出处。如发现内容问题,请通过联系我们页面反馈。













