侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 中国象棋ai
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

python通过socket实现多个连接并实现ssh功能详解

Python  /  管理员 发布于 7年前   274

一、前言

  上一篇中我们已经知道了客户端通过socket来连接服务端,进行了一次数据传输,那如何实现客户端多次发生数据?而服务端接受多个客户端呢?

二、发送中文信息

  在python3中,socket只能发送bytes类型的数据,bytes类型只能表示0-225的ASCII码的值,并不能表示中文,所以当我们需要发送中文时,需要使用到编码和解码。

客户端:

import socket# 客户端# 声明协议类型,同时生成socket对象client = socket.socket()#client.connect(('localhost', 8888))# python3 接收字节流数据msg = input('>>:').strip()client.send(msg.encode('utf-8')) # 先编码成utf-8格式data = client.recv(1024) # 1024字节的数据print(data)print(data.decode())

服务端:

import socket# 声明协议类型server = socket.socket()# 绑定本地网卡(多网卡选择),端口server.bind(('localhost', 8888))# 监听端口server.listen() # 监听# conn 就是客户端连接后,在服务器端为其生成的一个连接实例# address 是客户端的 hostaddr,portconn, address = server.accept()print("进入等待时间....")# 等待# print(conn, address)print("收到连接....")# 接收数据data_server = conn.recv(1024)print('receive:', data_server.decode()) # 解码# 返回一个值conn.send(data_server)

三、Socket实现多个连接

  这个事例需要在Linux环境下测试,在windows中测试时,多个客户端同时连接(也就是同时运行多个socket_client.py程序),其中一个断开,服务端会报错。Linux环境python版本为3.5。

  事例代码:

客户端:

import socket# 客户端# 声明协议类型,同时生成socket对象client = socket.socket()#client.connect(('localhost', 8888))# python3 接收字节流数据while True:  msg = input('>>:').strip()  if len(msg) == 0:   # 输入不能为空    continue  client.send(msg.encode('utf-8'))  data = client.recv(1024) # 1024字节的数据  print(data)  print(data.decode())

  事例中输入为空(即len(msg==0))是不可以的,如果不输入任何东西,socket程序默认等待你的输入,所以程序会卡掉。

服务端:

# -*- coding: UTF-8 -*-import socket# 声明协议类型server = socket.socket()# 绑定本地网卡(多网卡选择),端口server.bind(('localhost', 8888))# 监听端口server.listen(5) # 监听while True:  conn, address = server.accept()  print("进入等待时间....")  while True:    print("收到连接....")    # 接收数据    data_server = conn.recv(1024)    if not data_server:  # 这里判断客户端断开的情况,不控制会无限循环      print('client is lost...')      break    print('receive:', data_server.decode())    # 返回一个值    conn.send(data_server)

  在Linux服务器上,我开启了6个客户端,每个客户端输入一次就断开(即显示了client has lost...),服务端分别和六个客户端连接并接收数据。

四、实现ssh功能

4.1 测试环境

  服务端: 172.16.200.49,监听端口('0.0.0.0', 8888),Linux系统

  客户端:本机win10

4.2 测试代码

  服务端:

# -*- coding: UTF-8 -*-import socketimport os# 声明协议类型server = socket.socket()# 绑定本地网卡(多网卡选择),端口server.bind(('0.0.0.0', 8888))# 监听端口server.listen() # 监听while True:  conn, address = server.accept()  print("进入等待时间....")  while True:    print("收到连接....")    # 接收数据    data_server = conn.recv(1024)    if not data_server:      print('client is lost...')      break    res = os.popen("{}".format(data_server.decode())).read() # 将执行命令的结果存储返回    # 返回结果    conn.send(res.encode('utf-8'))

  客户端:

# -*- coding: UTF-8 -*-import socket# 客户端# 声明协议类型,同时生成socket对象client = socket.socket()#client.connect(('172.16.200.49', 8888)) # 服务端ip和端口# python3 接收字节流数据while True:  msg = input('>>:').strip()  if len(msg) == 0:    continue  client.send(msg.encode('utf-8'))  data = client.recv(1024) # 1024字节的数据  print(data.decode())

  结果如下:

  注:socket中recv()和send()函数接收和发送数据大小都是有限制的。如果一次发送太大,客户端接收不完,就会先存储在缓存当中。但是下一次命令,客户端接收的还是上次命令没有发完的数据。

四、模拟FTP上传文件

  本例当服务端在Linux环境中,struck模块有些问题....,目前在win10中可以正常运行

  服务端: 

# -*- coding: UTF-8 -*-import structimport socketclass FtpServer(object):  def __init__(self, host, port):    self.host = host    self.port = port  def ftp_server(self):    # 声明协议类型    ftp_server = socket.socket()    # 绑定本地网卡(多网卡选择),端口    ftp_server.bind((self.host, self.port))    # 监听端口    ftp_server.listen() # 监听    while True:      print('等待...')      conn, address = ftp_server.accept()      while True:        file_info = struct.calcsize('128sl')        buf = conn.recv(file_info)        if buf:          file_name, file_size = struct.unpack('128sl', buf)          # 使用strip()删除打包时附加的多余空字符          file_new_name = file_name.decode().strip('\00')          print('start receiving...')          fw = open(file_new_name, 'wb')          received_size = 0 # 接收文件的大小          while not received_size == file_size:if file_size - received_size > 1024:  r_data = conn.recv(1024)  received_size += len(r_data)else:  r_data = conn.recv(file_size - received_size)  received_size = file_sizefw.write(r_data)          fw.close()if __name__ == '__main__':  server = FtpServer('localhost', 8888)  server.ftp_server()

  客户端:

# -*- coding: UTF-8 -*-import socketimport osimport structclass FtpClient(object):  # 定义一个FtpClien类  def __init__(self, host, port):    self.host = host    self.port = port  def client_push(self):    # 声明协议类型,同时生成socket对象    ftp_client = socket.socket()    # 连接服务端    ftp_client.connect((self.host, self.port))    while True:      # 切换文件目录路径      print("输入文件目录路径")      pwd = input(">>:").strip()      # 列出文件名称      files_list = os.listdir('{}'.format(pwd))      for i in files_list:        print(i)      file_name = input('输入上传的文件名:').strip()      file_path = os.path.join(pwd, file_name)      if os.path.isfile(file_path):        file_info = struct.calcsize('128sl') # 定义打包规则        f_head = struct.pack('128sl', file_name.encode('utf-8'), os.stat(file_path).st_size)        ftp_client.send(f_head)        fo = open(file_path, 'rb')        while True:          file_data = fo.read(1024)          if not file_data:break          ftp_client.send(file_data)        fo.close()        # 上传文件        ftp_client.send(file_data)# client.close()if __name__ == '__main__':  client = FtpClient('localhost', 8888)  client.client_push()

  结果:

 在socket_server.py文件位置处能看到上传的文件

总结

以上就是本文关于python通过socket实现多个连接并实现ssh功能详解的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站:Python入门之三角函数全解【收藏】、Python基础练习之用户登录实现代码分享、python好玩的项目―色情图片识别代码分享等,有什么问题可以随时留言,小编会及时回复大家的。感谢朋友们对本站的支持!


  • 上一条:
    python执行使用shell命令方法分享
    下一条:
    Python基础练习之用户登录实现代码分享
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • 在python语言中Flask框架的学习及简单功能示例(0个评论)
    • 在Python语言中实现GUI全屏倒计时代码示例(0个评论)
    • Python + zipfile库实现zip文件解压自动化脚本示例(0个评论)
    • python爬虫BeautifulSoup快速抓取网站图片(1个评论)
    • vscode 配置 python3开发环境的方法(0个评论)
    • 近期文章
    • 智能合约Solidity学习CryptoZombie第三课:组建僵尸军队(高级Solidity理论)(0个评论)
    • 智能合约Solidity学习CryptoZombie第二课:让你的僵尸猎食(0个评论)
    • 智能合约Solidity学习CryptoZombie第一课:生成一只你的僵尸(0个评论)
    • 在go中实现一个常用的先进先出的缓存淘汰算法示例代码(0个评论)
    • 在go+gin中使用"github.com/skip2/go-qrcode"实现url转二维码功能(0个评论)
    • 在go语言中使用api.geonames.org接口实现根据国际邮政编码获取地址信息功能(1个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf分页文件功能(0个评论)
    • gmail发邮件报错:534 5.7.9 Application-specific password required...解决方案(0个评论)
    • 欧盟关于强迫劳动的规定的官方举报渠道及官方举报网站(0个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf文件功能(0个评论)
    • 近期评论
    • 122 在

      学历:一种延缓就业设计,生活需求下的权衡之选中评论 工作几年后,报名考研了,到现在还没认真学习备考,迷茫中。作为一名北漂互联网打工人..
    • 123 在

      Clash for Windows作者删库跑路了,github已404中评论 按理说只要你在国内,所有的流量进出都在监控范围内,不管你怎么隐藏也没用,想搞你分..
    • 原梓番博客 在

      在Laravel框架中使用模型Model分表最简单的方法中评论 好久好久都没看友情链接申请了,今天刚看,已经添加。..
    • 博主 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 @1111老铁这个不行了,可以看看近期评论的其他文章..
    • 1111 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 网站不能打开,博主百忙中能否发个APP下载链接,佛跳墙或极光..
    • 2016-10
    • 2016-11
    • 2018-04
    • 2020-03
    • 2020-04
    • 2020-05
    • 2020-06
    • 2022-01
    • 2023-07
    • 2023-10
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客