2

嗨，我正在编写一个通过消息队列发送一组字节的程序，就像这样......

#include <sys/msg.h>
#include <stddef.h>

key_t key;
int msqid;
struct pirate_msgbuf pmb = {2, { "L'Olonais", 'S', 80, 10, 12035 } };

key = ftok("/home/beej/somefile", 'b');
msqid = msgget(key, 0666 | IPC_CREAT);

/* stick him on the queue */
msgsnd(msqid, &pmb, sizeof(struct pirate_msgbuf) - sizeof(long), 0);

上面的例子是一个来自beejs网站的简单程序，类似于我的。

然而，我正在做的是发送一条带有这样结构的消息......

struct msg_queue{

    long message_type;
    char * buffer;

}

现在，在我发送我的 msg_queue 之前，我创建了一些替代缓冲区，其中包含各种信息，包括空字符等。现在当我做这样的事情时......

struct msg_queue my_queue;
my_queue.message_type = 1;
my_queue.buffer = "My message";
msgsnd(mysqid, &pmb, sizeof(struct msg_queue) - sizeof(long), 0);

我接收指针和读取存储在该字符串中的值没有问题。但是，如果我要做类似的事情......

struct msg_queue my_queue;
my_queue.message_type = 1;
my_queue.buffer = sum_buffer_with_lots_of_weird_values; // of type char *
msgsnd(mysqid, &pmb, sizeof(struct msg_queue) - sizeof(long), 0);

我通过队列传递给其他进程的指针将读取垃圾而不是存储的值。我尝试将我的任意数组设为静态字符 *，但这也无济于事。如何通过队列正确传递缓冲区？谢谢。

4

3 回答 3

5

您不应该向另一个进程发送指针，它们在另一个进程的地址空间中没有意义（或指向非常不同的东西）。

消息队列不适用于可变长度字符串等无限数据。将指针更改为足够大以容纳最大字符串的固定长度 char 数组，并在写入队列之前将字符串复制到数组中。或者使用其他类型的 IPC，例如域套接字。

于 2012-10-31T01:06:23.553 回答
2

消息队列用于进程间通信。当您在一个进程中 malloc 一些内存时，它只存在于该进程的内存空间中，其他进程无法访问。

当您发送该指针时，您正在发送一个不可访问的地址空间。它甚至可能导致分段错误。

一种方法是限制缓冲区大小（如果适用）。

结构 msg_queue{

long message_type;
char buffer[MAX_LEN];

}

另一种方法是发送2次。第一个 msgsnd 发送期望的缓冲区大小。下一次发送，您使用第一次发送的大小发送 char 数组。:)

在接收端，您首先获取大小，然后接收缓冲区。

其他方法是使用管道或套接字。

于 2012-10-31T08:50:06.110 回答
1

“msgsend()”只会读取缓冲区中的字节。

如果其中一个字节碰巧是一个指针（指向其他地方的某个字符串或对象）......猜猜是什么 - 接收者只会得到二进制指针。不是指向的数据。

您需要做的是将消息的全部内容打包到缓冲区中，然后发送该线性缓冲区。

于 2012-10-31T01:06:38.240 回答