AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • 主页
  • 系统&网络
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • 主页
  • 系统&网络
    • 最新
    • 热门
    • 标签
  • Ubuntu
    • 最新
    • 热门
    • 标签
  • Unix
    • 最新
    • 标签
  • DBA
    • 最新
    • 标签
  • Computer
    • 最新
    • 标签
  • Coding
    • 最新
    • 标签
主页 / unix / 问题 / 748458
Accepted
David Scherfgen
David Scherfgen
Asked: 2023-06-10 06:56:14 +0800 CST2023-06-10 06:56:14 +0800 CST 2023-06-10 06:56:14 +0800 CST

是否有一个程序可以连接不可搜索的流(大小事先不知道)并可以再次将它们分开?

  • 772

我正在尝试将多个输入文件/流连接成一个流(使用虚构命令stream-cat),将该流通过管道传输到ssh远程主机并在远程主机上将其分离回单独的文件/流(stream-sep),如本例所示,用于演示仅用于:

stream-cat <( zfs send tank/vm@snapshot ) somefile.txt | ssh user@host "stream-sep >( zfs receive tank/vm@snapshot ) somefile.txt"

示例说明:zfs send输出大量数据,其大小事先未知(这就是tar无法处理的原因)。该数据流与常规文件的内容连接在一起somefile.txt。生成的流通过管道输送到ssh,在那里再次分离。第一个流通过管道传输到zfs receive,而第二个流写入常规文件。

这样的程序应该通过读取块中的不可搜索流并始终写入块大小后跟数据来实现,直到到达流的末尾。开销将是最小的。

这样的程序已经存在了吗?

pipe
  • 2 2 个回答
  • 45 Views

2 个回答

  • Voted
  1. Best Answer
    Marcus Müller
    2023-06-10T16:45:40+08:002023-06-10T16:45:40+08:00

    您所描述的是多路复用;需要协议的东西(即关于如何处理数据的正式规范)。

    有很多方法可以做到这一点。例如,您会注意到您的计算机可以完美地同时通过 HTTP 下载多个文件——即使是从同一台服务器。该功能首先由 TCP 提供给您,作为传输协议,它允许在接收端发送和“分解”不同的流。

    所以,TCP 已经提供了该功能,您可以简单地启动两个并发 SSH 连接并使用它!

    zfs send | zstd -10 | ssh user@host 'zstd -d | zfs receive tank/vm@snapshot' &
    # ^         ^    ^     ^             ^     ^   ^                             ^
    # |         |    |     |             |     |   |                             |
    # |         |    |     |             |     |   |     Tell your own shell to run
    # |         |    |     |             |     |   |     this in the background and
    # |         |    |     |             |     |   |     not block
    # |         |    |     |             |     |   |                         
    # |         |    |     |             |     |   |                            
    # |         |    |     |             |     |   \---- Program to receive in the end
    # |         |    |     |             |     |
    # |         |    |     |             \-----+-------- use zstd to decompress
    # |         |    |     |                             received data
    # |         |    |     |            
    # |         |    |     |
    # |         |    |     \---------------------------- our first ssh invocaton
    # |         |    |
    # |         \----+---------------------------------- use zstd to compress at medium
    # |                                                  high compression level (10)
    # |
    # \------------------------------------------------- the first program whose output
    #                                                    we send
    
    cat somefile.txt | ssh user@host 'cat > somefile.txt'
    #                                                    Second SSH connection
    

    当然,cat somefile.txt | ssh … > somefile.txt您可能只是使用scp somefile.txt user@host:somefile.txt(它在后台使用 SSH,但不进行 shell 连接,而是使用 SSH 中内置的 SCP 层来复制文件),而不是稍微不优雅的 。

    您可以通过将以下内容添加到文件中来更快地建立第二个连接~/.ssh/config:

    ControlMaster auto
    ControlPath /tmp/.ssh-socket-%h_%p_%r
    

    这将告诉 SSH 尝试并重新使用一个 SSH 会话同时发送多个加密流(这适用于scp和ssh的任意组合)。

    • 2
  2. Stéphane Chazelas
    2023-06-10T21:44:18+08:002023-06-10T21:44:18+08:00

    这些的粗略实现stream-cat可以stream-sep很容易地写成perl:

    stream-cat() {
      perl -ne 'BEGIN{$/ = \0x7fff}
                print pack("n", $c|length()<<1), $_;
                $c = !eof' -- "$@"
    }
    stream-sep() {
      perl -e 'while($/ = \2, $_ = <STDIN>) {
                 $n = unpack "n";
                 open OUT, shift@ARGV unless $n & 1;
                 if ($n>>=1) {$/ = \$n; $_ = <STDIN>; print OUT}
               }' -- "$@"
    }
    

    #! /bin/sh -或与脚本而不是函数相同sh。

    (错误处理留给读者作为练习:-)。

    stream-cat发送最大为 32767 字节的记录,前缀为n网络编码(大端)短,其最低位指示它是新流 (0) 的开始还是继续,其余位是大小。

    然后,例如:

    $ cat a
    test
    $ stream-cat 'seq 10|' a | stream-sep '|wc -l' '>b'
    10
    $ cat b
    test
    

    所以在你的情况下:

    stream-cat 'zfs send tank/vm@snapshot|' somefile.txt |
      ssh user@host 'stream-sep "|zfs receive tank/vm@snapshot" ">somefile.txt"'
    

    在极少数情况下,不安全形式的open(此处也被使用<>)-n允许<file以>file只读或只写模式打开文件或|cmd通过cmd|管道输入/输出命令实际上很有用。

    使用那些|cmd/比你的/cmd|更好,因为一次只有一个打开,所以你可以毫无问题地发送数千个单独的流。<(cmd)>(cmd)

    • 2

相关问题

  • 如何在 bash 中使用“sudo”调用时将“yes”或“y”通过管道传输到程序中?

  • 将句柄传递给标准输入下行管道

  • 如何通过管道传输 bash 命令并保持 Ctrl+C 正常工作?

  • 为什么管道`mysql`到'tail'会改变输出格式?

  • `tee` 和 `bash` 进程替换顺序

Sidebar

Stats

  • 问题 205573
  • 回答 270741
  • 最佳答案 135370
  • 用户 68524
  • 热门
  • 回答
  • Marko Smith

    模块 i915 可能缺少固件 /lib/firmware/i915/*

    • 3 个回答
  • Marko Smith

    无法获取 jessie backports 存储库

    • 4 个回答
  • Marko Smith

    如何将 GPG 私钥和公钥导出到文件

    • 4 个回答
  • Marko Smith

    我们如何运行存储在变量中的命令?

    • 5 个回答
  • Marko Smith

    如何配置 systemd-resolved 和 systemd-networkd 以使用本地 DNS 服务器来解析本地域和远程 DNS 服务器来解析远程域?

    • 3 个回答
  • Marko Smith

    dist-upgrade 后 Kali Linux 中的 apt-get update 错误 [重复]

    • 2 个回答
  • Marko Smith

    如何从 systemctl 服务日志中查看最新的 x 行

    • 5 个回答
  • Marko Smith

    Nano - 跳转到文件末尾

    • 8 个回答
  • Marko Smith

    grub 错误:你需要先加载内核

    • 4 个回答
  • Marko Smith

    如何下载软件包而不是使用 apt-get 命令安装它?

    • 7 个回答
  • Martin Hope
    user12345 无法获取 jessie backports 存储库 2019-03-27 04:39:28 +0800 CST
  • Martin Hope
    Carl 为什么大多数 systemd 示例都包含 WantedBy=multi-user.target? 2019-03-15 11:49:25 +0800 CST
  • Martin Hope
    rocky 如何将 GPG 私钥和公钥导出到文件 2018-11-16 05:36:15 +0800 CST
  • Martin Hope
    Evan Carroll systemctl 状态显示:“状态:降级” 2018-06-03 18:48:17 +0800 CST
  • Martin Hope
    Tim 我们如何运行存储在变量中的命令? 2018-05-21 04:46:29 +0800 CST
  • Martin Hope
    Ankur S 为什么 /dev/null 是一个文件?为什么它的功能不作为一个简单的程序来实现? 2018-04-17 07:28:04 +0800 CST
  • Martin Hope
    user3191334 如何从 systemctl 服务日志中查看最新的 x 行 2018-02-07 00:14:16 +0800 CST
  • Martin Hope
    Marko Pacak Nano - 跳转到文件末尾 2018-02-01 01:53:03 +0800 CST
  • Martin Hope
    Kidburla 为什么真假这么大? 2018-01-26 12:14:47 +0800 CST
  • Martin Hope
    Christos Baziotis 在一个巨大的(70GB)、一行、文本文件中替换字符串 2017-12-30 06:58:33 +0800 CST

热门标签

linux bash debian shell-script text-processing ubuntu centos shell awk ssh

Explore

  • 主页
  • 问题
    • 最新
    • 热门
  • 标签
  • 帮助

Footer

AskOverflow.Dev

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve