rt_mq_t rt_mq_create(const char *name,
                     rt_size_t   msg_size,
                     rt_size_t   max_msgs,
                     rt_uint8_t  flag);
复制代码

rt_err_t rt_mq_delete(rt_mq_t mq);
复制代码

rt_err_t rt_mq_init(rt_mq_t     mq,
                    const char *name,
                    void       *msgpool,
                    rt_size_t   msg_size,
                    rt_size_t   pool_size,
                    rt_uint8_t  flag);
复制代码

rt_err_t rt_mq_detach(rt_mq_t mq);
复制代码

rt_err_t rt_mq_send (rt_mq_t mq, void* buffer, rt_size_t size);
复制代码

rt_err_t rt_mq_urgent(rt_mq_t mq, void* buffer, rt_size_t size);
复制代码

rt_err_t rt_mq_recv(rt_mq_t    mq,
                    void      *buffer,
                    rt_size_t  size,
                    rt_int32_t timeout);
复制代码

/* 线程句柄 */
static rt_thread_t thread1 = RT_NULL;
static rt_thread_t thread2 = RT_NULL;
 
/* 消息队列句柄 */
static rt_mq_t msgqueue1 = RT_NULL;
 
 
/**************************************************************
函数名称 : thread1_recv_msgqueue
函数功能 : 线程1入口函数，用于接收消息
输入参数 : parameter：入口参数
返回值           : 无
备注                 : 无
**************************************************************/
void thread1_recv_msgqueue(void *parameter)
{
        u8 key;
        char buf[64];
        
        while(1)
        {
                key = key_scan(0);
                
                if(key== KEY2_PRES)
                {        
                        if(rt_mq_recv(msgqueue1, buf, sizeof(buf), RT_WAITING_FOREVER) == RT_EOK)
                        {
                                rt_kprintf("recv msg:%s\r\n", buf);
                        }
                        else
                        {
                                rt_kprintf("recv msg failed\r\n");
                        }
                }
                
                rt_thread_mdelay(1);
        }
}
 
/**************************************************************
函数名称 : thread2_send_mailbox_msg
函数功能 : 线程2入口函数，用于发送消息
输入参数 : parameter：入口参数
返回值           : 无
备注                 : 无
**************************************************************/
void thread2_send_msgqueue(void *parameter)
{
        u8 key;
        rt_err_t res;
        
        while(1)
        {
                key = key_scan(0);
                
                if(key== KEY0_PRES)
                {
                         res = rt_mq_send(msgqueue1, "msg1", sizeof("msg1"));
 
                         if(res == RT_EOK)
                         {
                                rt_kprintf("msgqueue send msg1 successful\r\n");
                         }
                         else
                         {
                                rt_kprintf("msgqueue send msg1 failed\r\n");
                         }
                }
                else if(key== KEY1_PRES)
                {
                         rt_mq_urgent(msgqueue1, "msg2", sizeof("msg2"));
                        
                         if(res == RT_EOK)
                         {
                                rt_kprintf("msgqueue send msg2 successful\r\n");
                         }
                         else
                         {
                                rt_kprintf("msgqueue send msg2 failed\r\n");
                         }
                }
                
                rt_thread_mdelay(1);
        }
}
 
 
void rtthread_msgqueue_test(void)
{
        msgqueue1 = rt_mq_create("msgqueue1", 
                                64, /* 消息最大长度 */
                                10, /* 消息队列最大容量 */
                                RT_IPC_FLAG_FIFO);/* FIFO模式 */
        
        if(msgqueue1 != RT_NULL)
        {
                rt_kprintf("RT-Thread create msgqueue successful\r\n");
        }
        else
        {
                rt_kprintf("RT-Thread create msgqueue failed\r\n");
                return;
        }
 
        thread1 = rt_thread_create("thread1",
                                thread1_recv_msgqueue,
                                NULL,
                                512,
                                3,
                                20);
 
        if(thread1 != RT_NULL)
        {
                rt_thread_startup(thread1);;
        }
        else
        {
                rt_kprintf("create thread1 failed\r\n");
                return;
        }
 
        thread2 = rt_thread_create("thread2",
                                thread2_send_msgqueue,
                                NULL,
                                512,
                                2,
                                20);
 
        if(thread2 != RT_NULL)
        {
                rt_thread_startup(thread2);;
        }
        else
        {
                rt_kprintf("create thread2 failed\r\n");
                return;
        }
        
}
复制代码

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)
    {
        /* 成 功 接 收 到 消 息， 进 行 相 应 的 数 据 处 理 */
    }
}
复制代码

struct msg
{
    /* 消 息 结 构 其 他 成 员 */
    struct rt_semaphore ack;
};
复制代码

struct msg
{
    /* 消 息 结 构 其 他 成 员 */
    struct rt_mailbox ack;
};
复制代码