Perl中的消息队列

Question

我想用Perl实现一个消息队列。我从stdin获取数据并将其发送到队列。

我邮件的结构是

struct message => {
    mtype        => '$',
    buffer_size  => '$',
    last_message => '$',
    buff         => '$',
};

我必须使用C程序从队列中接收数据。我的C程序以前运行良好，但是现在当我运行它以从队列中接收数据时，它显示出类似以下内容

age=HASH(0x1daa088) 1936942445      4000        

我使用在stdout上打印的4000字节缓冲区读取数据块。但是age=HASH(0x1daa088) 1936942445程序应该打印收到的消息的大小，而不是打印出来。

这里发生了什么？是因为C中的消息是结构，而Perl中的消息是哈希吗？

我的C代码：

age=HASH(0x1daa088) 1936942445      4000        

我的Perl代码：

#include <stdio.h>
#include <stdlib.h>
#include <linux/ipc.h>
#include <linux/msg.h>
#include <time.h>
#include <string.h>

#define bufsize 4000

struct mymsgbuf {
    long    mtype;          /* Message type */
    int     buffer_size;
    char    buff[bufsize];
    int     last_message;
} msg;

int read_message( int qid, long type, struct mymsgbuf *qbuf ) {

    int result, length;

    /* The length is essentially the size of the structure minus   sizeof(mtype)*/

    length = sizeof(struct mymsgbuf) - sizeof(long);

    if ( (result = msgrcv( qid, qbuf, length, type, MSG_NOERROR)) == -1 ) {
        return(-1);
    }

    fprintf(stderr, "\t%d\t\t%d\t\t%d  \n", qbuf->buffer_size, bufsize, qbuf->last_message);

    write(1,qbuf->buff,qbuf->buffer_size);

    return(result);
}

int open_queue( key_t keyval ) {

    int qid;

    if ( (qid = msgget( keyval, 0660 )) == -1 ) {
        return(-1);
    }

    return(qid);
}

main() {

    int     qid;
    key_t   msgkey;
    msg.last_message = 0;

    /* Generate our IPC key value */
    msgkey = ftok("/home/joobeen/Desktop/learning", 'm');

    /* Open/create the queue */
    if (( qid = open_queue( msgkey)) == -1) {
        perror("open_queue");
        exit(1);
    }

    fprintf(stderr, "byte received:\tbuffer_size:\tlast_message:\n");

    /* Bombs away! */
    while (1) {

        if ( (read_message( qid,0, &msg )) == -1 ) {
            perror("receive_message");
            exit(1);
        }
        if ( msg.last_message == 1 )
            break;
    }

    return 0;
}

Answer 1

您的代码有多个问题。我不会为您全部修复它们，但是我可以为您提供一些有关总体上如何实施IPC的指南。

将二进制数据直接读取到C结构中非常脆弱。您必须关心字节顺序，结构填充以及诸如int或类型的大小long。根据您的平台，这两种类型都可能是32位或64位，并且字节序很小或很大。因此，首先，您需要准确定义消息的“在线协议”。为简化起见，让我们使用固定大小的消息：

mtype: 32-bit unsigned integer, little endian
buffer_size: 32-bit unsigned integer, little endian
buffer: 4000 bytes
last_message: 32-bit unsigned integer, little endian

这只是一个例子。您也可以使用大尾数整数，就像大多数网络协议出于历史原因一样。如果只想在一台计算机上使用IPC，则还可以指定本机字节顺序。

现在，消息的长度固定为4012字节。要在C语言中以可移植的方式解码此类消息，应将其读入char数组并分别提取每个字段。您知道每个字段的偏移量和大小。

使用以下pack功能在Perl中编码这样的消息很容易：

my $msg = pack('V V a4000 V', $mtype, $buffer_size, $buffer, $last);

不需要Class::Struct。该模块无法满足您的期望。