Início / unix / Perguntas / 458951
Accepted
abc
Asked: 2018-07-28 12:43:14 +0800 CST

Como posso adicionar delimitadores de mensagem a um fluxo UDP que socat está canalizando?

  • 772

Estou usando socatpara interceptar mensagens UDP e enviá-las para um pipe nomeado:

socat UDP-LISTEN:9999,fork PIPE:/tmp/mypipe,append

Eu sou capaz de seguir esse tubo e ver todas as mensagens que ele recebe.

Eu gostaria de canalizar a saída de tail -f /tmp/mypipepara sedfazer algum pós-processamento das mensagens, mas infelizmente algumas delas não são terminadas por nova linha. Isso é um problema porque significa que várias mensagens UDP distintas podem estar na mesma linha e também porque tail -f /tmp/mypipe | sed ...não passa a última linha se não for terminada.

Idealmente, eu gostaria de poder adicionar um delimitador de mensagens personalizado à medida que elas são enviadas ao meu pipe, para que eu possa encontrar facilmente os limites da mensagem. Se isso não for possível, existe alguma maneira de seguir esse arquivo e canalizar a linha final (potencialmente não terminada) para outro programa para pós-processamento?

socat

2 respostas

  1. Best Answer

    Uma possibilidade que não envolve bifurcação é usar a socatsaída detalhada em vez dos dados. Minha versão de socat -vinclui o comprimento dos dados na saída detalhada, para que você saiba onde termina. Por exemplo,

    mkfifo mypipe
while sleep 3
do    printf "%sNONEWLINE" $RANDOM
done |
socat -u - UDP4:localhost:9999  &
socat -u -v UDP-RECV:9999 - >/dev/null 2>mypipe  &
cat -uv mypipe

    produzirá antes de cada item de dados (por exemplo 9430NONEWLINE) um cabeçalho começando >com a data e um comprimento.

    > 2018/07/28 10:29:33.965222  length=13 from=0 to=12
9430NONEWLINE> 2018/07/28 10:29:36.968335  length=14 from=13 to=26
26947NONEWLINE> 2018/07/28 10:29:39.971025  length=14 from=27 to=40
15126NONEWLINE
    • 3

  2. Use sed, que pode anexar uma nova linha com um único comando, para evitar a condição de corrida ao usar SYSTEM:"cat; echo \"\n\""a saída:

    socat -u UDP-RECVFROM:9999,fork SYSTEM:"sed -e a\\\\"

    • 2

relate perguntas