使用消息队列发送不定长数据一些小疑问

发布于 2019-02-13 16:15:42 浏览：2362 订阅该版

* 本帖最后由 小住住 于 2019-2-13 17:18 编辑 *

按下面的说法：我在onenet线程中  的命令响应回掉函数中,增加发送消息队列到打印线程，但打印的是乱码，不是自己下发的命令。这块的处理，有什么要注意的吗？到打印的时候，原来指针所指的内容好像已经变了。最终测试，这种场合，还是需要源数据是固定不变的的场合。原先的局部变量，执行完回掉函数后，原来的数就变了。所以这种场合还是需要全局变量或者一个静态变量。
```/* onenet mqtt command response callback function */
static void onenet_cmd_rsp_cb(uint8_t *recv_data, size_t recv_size, uint8_t **resp_data, size_t *resp_size)
{
    char res_buf[] = { "cmd is received!<br>" };

log_d("recv data is %.*s<br>", recv_size, recv_data);
    rs485_transport(recv_data,recv_size);
    /* user have to malloc memory for response data */
    *resp_data = (uint8_t *) ONENET_MALLOC(strlen(res_buf));

strncpy(*resp_data, res_buf, strlen(res_buf));

*resp_size = strlen(res_buf);
                
}```
```static rt_uint8_t temp_data[20];
void rs485_transport(uint8_t *recv_data, size_t recv_size)
{
          int result;
                struct msg msg_ptr;
             //增加一句 先  把数据复制到静态变量中。
               strncpy(temp_data, recv_data, recv_size);
                msg_ptr.data_ptr = temp_data;//recv_data;
                msg_ptr.data_size = recv_size;
    rt_pin_write(RS485_RE_DE_Pin, PIN_HIGH);
/* 发送消息到消息队列中 */
            result = rt_mq_send(&mq,(void*)&msg_ptr,sizeof(struct msg));
            if (result != RT_EOK)
            {
                rt_kprintf("rt_mq_send ERR<br>");
            }

rt_kprintf("thread onenet: send message - %s<br>", msg_ptr.data_ptr);
    //rt_pin_write(RS485_RE_DE_Pin, PIN_LOW);
}

接收处理：
static void serial_thread_entry(void *parameter)
{
    char buf;
    rt_uint8_t k;
        struct msg msg_prt;
    while (1)
    {

/* 从消息队列中接收消息 */

if (rt_mq_recv(&mq, (void*)&msg_prt, sizeof(struct msg), RT_WAITING_FOREVER) == RT_EOK)
        {
        
                        rt_device_write(serial, 0, (void*)msg_prt.data_ptr, msg_prt.data_size);
        }
    
    }
}
```
![1.png](/uploads/201902/13/161302arsbb08rqjhxxsxs.png)
![2.png](/uploads/201902/13/161331yef7zxr7xhilxipd.png)
修改添加静态变量后的结果：
![3.png](/uploads/201902/13/171807s4u816h6gupbhugc.png)

```发送消息

消息队列和邮箱的明显不同是消息的长度并不限定在 4 个字节以内；另外，消息队列也包括了一个发送紧急消息的函数接口。但是当创建的是一个所有消息的最大长度是 4 字节的消息队列时，消息队列对象将蜕化成邮箱。这个不限定长度的消息，也及时的反应到了代码编写的场合上，同样是类似邮箱的代码：

struct msg
{
    rt_uint8_t *data_ptr;    /* 数据块首地址 */
    rt_uint32_t data_size;   /* 数据块大小   */
};

和邮箱例子相同的消息结构定义，假设依然需要发送这样一个消息给接收线程。在邮箱例子中，这个结构只能够发送指向这个结构的指针（在函数指针被发送过去后，接收线程能够正确的访问指向这个地址的内容，通常这块数据需要留给接收线程来释放）。而使用消息队列的方式则大不相同：

void send_op(void *data, rt_size_t length)
{
    struct msg msg_ptr;

msg_ptr.data_ptr = data;  /* 指向相应的数据块地址 */
    msg_ptr.data_size = length; /* 数据块的长度 */

/* 发送这个消息指针给 mq 消息队列 */
    rt_mq_send(mq, (void*)&msg_ptr, sizeof(struct msg));
}

注意，上面的代码中，是把一个局部变量的数据内容发送到了消息队列中。在接收线程中，同样也采用局部变量进行消息接收的结构体：

void message_handler()
{
    struct msg msg_ptr; /* 用于放置消息的局部变量 */

/* 从消息队列中接收消息到 msg_ptr 中 */
    if (rt_mq_recv(mq, (void*)&msg_ptr, sizeof(struct msg)) == RT_EOK)
    {
        /* 成功接收到消息，进行相应的数据处理 */
    }
}

因为消息队列是直接的数据内容复制，所以在上面的例子中，都采用了局部变量的方式保存消息结构体，这样也就免去动态内存分配的烦恼了（也就不用担心，接收线程在接收到消息时，消息内存空间已经被释放）。```