使用 SOCAT 记录在端口上接收的消息

Question

我有一个带有开放端口的服务器，每秒接收 50 到 1000 条消息。 通过消息，我的意思是发送一行文本。

本质上，我们希望将这些消息记录在一个文件中，该文件将每小时（或x分钟）处理一次。

我创建了一个在后台运行的 bash 脚本（见下文），它可以工作，除非我杀死 socat 进程（这样我就可以处理文件并且它可以启动一个新文件）我们得到消息的一部分，而且我确定我们在 socat 关闭的那一瞬间丢失了消息。

DELAY="3600"
while true
do  
    NEXT_STOP=`date +%s --date "$DELAY second"`
    (
        while [ "$(date +%s)" -lt "$NEXT_STOP" ]
        do
            killall socat
            socat -u TCP-LISTEN:6116,reuseaddr,keepalive,rcvbuf=131071,reuseaddr OPEN:/var/ais/out_v4.txt,creat,append
        done
    ) & sleep $DELAY ; killall socat
    mv /var/ais/out_v4.txt "/var/ais/_socat_received/"$(date +"%Y-%m-%d-%T")"__out_v4.txt"
done

有没有办法：

1. 让 socat 在不终止进程的情况下旋转其输出文件
2. 或者我们可以在 SOCAT 写入文件时清除文件的内容。 例如，将前 10000 行剪切到另一个文件中，以便输出文件保持可管理的大小？

提前非常感谢

Answer 1

对于任何感兴趣的人，最终解决方案如下所示，与下面的 Nicholas 解决方案的主要区别在于我需要 grep socat进程的 PID 而不是使用 $？：

#!/bin/bash
DELAY=600
SOCAT_PID=$(/bin/ps -eo pid,args | grep "socat -u TCP-LISTEN:12456" | grep -v grep | awk '{ print $1 }')
while `kill -0 $SOCAT_PID`
do  
  touch /var/ais/out.txt
  NEXT_STOP=`date +%s --date "$DELAY second"`
  while  `kill -0 $SOCAT_PID` && [ "$(date +%s)" -lt "$NEXT_STOP" ]
  do
    head -q - >> /var/ais/out.txt
  done
  mv /var/ais/out.txt "/var/ais/_socat_received/"$(date +"%Y-%m-%d-%T")"__out.txt"
done

此外，在无限 while 循环中添加启动脚本，以便在客户端断开连接时我们重新启动 socat 并等待下一次连接尝试：

while true
do
socat -u TCP-LISTEN:12456,keepalive,reuseaddr,rcvbuf=131071 STDOUT | /var/ais/socat_write.sh
done

Answer 2

您可以使用 rotatelogs 或 multilog 来代替重新发明轮子，两者都读取 std 输入上的日志消息，并使用非常灵活的旋转配置将它们写入日志文件。

甚至更进一步，您描述的功能与 rsyslogd 等功能非常相似。

Answer 3

不是那么明显！ Socat没有任何选项可以更改中途连接的功能。这意味着你必须有点鬼鬼祟祟。将 socat 与输出一起使用为 STDOUT，并通过管道连接到此脚本：

#!/bin/bash
rv=0
while [ $rv -lt 1 ]
do  
  NEXT_STOP=`date +%s --date "$DELAY second"`
  while [ "$(date +%s)" -lt "$NEXT_STOP" ] && [ $rv -lt 1 ]
  do
    head -q - >> /var/ais/out_v4.txt
    rv=$?
  done
  mv /var/ais/out_v4.txt "/var/ais/_socat_received/"$(date +"%Y-%m-%d-%T")"__out_v4.txt"
done

完全未经测试，但看起来合理？

socat -u TCP-LISTEN:6116,reuseaddr,keepalive,rcvbuf=131071,reuseaddr STDOUT | ./thescript.sh