gpt4 book ai didi

c - Perl 中的消息队列

转载 作者:太空狗 更新时间:2023-10-29 16:11:10 25 4
gpt4 key购买 nike

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

我的消息结构是

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

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

age=HASH(0x1daa088) 1936942445      4000        

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

这里发生了什么?是因为消息在 C 中是一个结构,而在 Perl 中它是一个散列吗?

我的 C 代码:

#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;
}

我的 Perl 代码:

use strict;
use warnings;

use IPC::SysV qw(IPC_PRIVATE IPC_CREAT S_IRUSR S_IWUSR ftok);
use IPC::Msg;
use Class::Struct;

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

my $key_in = ftok( "/home/joobeen/Desktop/learning", 'm' );
my ( $buffer ) = "";
my $buf_size = 4000;
my $file = shift @ARGV;
my $ifh;
my $is_stdin = 0;
my $type_sent = 1;
my $last;

if ( defined $file ) {
open $ifh, "<", $file or die $!;
}
else {
$ifh = *STDIN;
$is_stdin++;
}

my $ipc_id = msgget( $key_in, IPC_CREAT | S_IRUSR | S_IWUSR );
my $msg = message->new(
mtype => 1,
last_message => 0
);

print "\tbyte sent\tbuffer_size\tlast_message\n";

while ( <$ifh> ) {

$last = read( $ifh, $buffer, $buf_size );

$msg->buff( $buffer );
$msg->buffer_size( $buf_size );

if ( $last < $buf_size ) {
$msg->last_message( 1 );
}

msgsnd( $ipc_id, pack( "l! a*", $type_sent, $msg ), 0 );

print "\t", $last, "\t\t", $buf_size, "\t\t", $msg->last_message, "\n";

}

close $ifh unless $is_stdin;

最佳答案

您的代码有多个问题。我不会为您解决所有问题,但我可以为您提供一些关于如何实现 IPC 的一般指南。

将二进制数据直接读入 C 结构是极其脆弱的。您必须关心字节顺序、结构填充和类型的大小,如 intlong。根据您的平台,这两种类型都可以是 32 位或 64 位以及小端或大端。因此,首先,您需要对消息的“在线协议(protocol)”有一个准确的规范。为了简化事情,让我们使用固定大小的消息:

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

这只是一个例子。您也可以使用大端整数,就像大多数网络协议(protocol)出于历史原因所做的那样。如果您只想在一台机器上使用 IPC,您还可以指定 native 字节顺序。

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

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

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

不需要 Class::Struct。该模块没有按照您的预期执行。

关于c - Perl 中的消息队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33911255/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com