ZWave 中的消息队列机制

Posted sewain

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ZWave 中的消息队列机制相关的知识,希望对你有一定的参考价值。

文章主题  

    在我们的日常编程中,对消息队列的需求非常常见,使用一个简洁、高效的消息队列编程模型,对于代码逻辑的清晰性,对于事件处理的高效率来说,是非常重要的。这篇文章就来看看 ZWave 中是通过什么机制为我们提供了一个便捷的消息队列处理机制。

 

内容导航  

  • 消息队列是什么

  • 我自己写的消息队列

  • ZWave 消息队列的结构

  • ZWave 消息队列的使用(初始化、存储消息、取出消息)

 

消息队列是什么  

    消息队列最主要特点是:存储消息,先进先出。

    比如在典型的生产者-消费者编程模型中,先创建一个消息队列,最大容量是 100。

    当生产者产生一条消息时,如果消息队列未满,就放进消息队列的尾部。

    消费者定期去检查消息队列中是否有消息,如果有,则取出最前面的那条消息进行处理,直到把队列中的所有消息都处理完。

    当然,如果链表来创建一个动态的消息队列也是可以的,这样就可以构成一个无容量限制的队列,这个模型有点复杂,咱们暂且不讨论它S。

技术分享图片

 技术分享图片

 

 我自己写的消息队列  

 

    在我自己的开发过程中,经常需要使用消息队列来保存多条消息,每一条消息都存储长度不等的字符串,于是就自己写了一个最简单的消息队列实现模板,当然对于项目来说也是最合适的,因为是量体裁衣嘛。

    一共2个文件(.h, .c),每次项目中需要用到时,就把这2个文件拷贝过来,再简单修改一下(保存的每条消息满足应用的需求),就直接用上了。简单、粗暴、有效、好用,每次都能很块就解决我的问题。

    这里简单截个图,如果需要,我可以免费分享!

技术分享图片

 

技术分享图片

    使用起来也比较简单,只需要3个步骤。

技术分享图片

 

技术分享图片

 

ZWave 消息队列的结构  

 技术分享图片

 

    ZWave SDK 的每一个 Sample 中已经给我们提供了一个很好的消息队列编程模型,不过它还嵌入了一个 task 任务管理的机制,后面我会简单画一下 task 的处理逻辑,但是不会深入探究。

    先来看一下 ZWave 提供的消息队列的结构。

技术分享图片

    请注意:这是消息队列的结构,而这个队列中存储的每一条消息是存储在一个数组缓冲区中,通过 array 指针进行引用。因此,在消息队列初始化的时候,必须提供一个数组,并把数组的地址赋值给 array 指针。

    关于这个数组,从代码中可以看到 QElementType 其实就是一个无符号字节,因此,这个消息队列仅仅能存储最最简单的消息,即:一个字节的数值。可以看一下 SwitchOnOff.c 中所存储的消息,都是 EVENT_APP 这个枚举类型的值。

 

ZWave 消息队列的使用  

1.消息队列的初始化

    在应用程序初始化的时候,ZWave 实例程序为我们已经创建好一个消息队列了,流程如下。

技术分享图片

    可以看到,一共有 2 个消息队列:eventQueue 和 jobQueue,这两个队列的实现机制都是一样的,只不过是把不同类型的消息放在不同的队列而已,因此,只要分析其中一个 eventQueue 就可以了。

    初始化完成之后,存储消息的数组是空的,消息队列的有效消息个数是 0。

技术分享图片

 

2.存储消息到消息队列

    就是把一条新消息放入消息队列的数组中,然后更新消息队列的一些状态参数,比如:有效消息长度,存储的这条消息位置等等。

    函数调用流程如下。

技术分享图片

技术分享图片

 

 

3.从消息队列中获取消息

     这个也很好理解,就是通过消息队列的结构检查一下是否有消息等待处理。如果是的话,就取出消息,并更新消息队列的一些状态参数。

    函数调用流程如下。   

技术分享图片

 

技术分享图片

    ZWave 文档中已经说明,协议层会定期调用应用层的函数 ApplicationPoll( ) ,这也是 ZWave 推荐的方式让应用层执行自己的逻辑,但是应用层不能在这个函数中执行太长时间。

    在这个函数中,我们可以直接去消息队列中取出一个消息。但是如果这么做的话,就浪费了 ZWave 为我们提供的 Task 机制,因此这里调用了 TaskApplicationPoll( ),然后我们应用层的事件处理函数 AppStateManager( ) 就老老实实的待着,等待别人把事件消息准备好、喂过来。

    其实,这也是一种分层编程思想,如下。

技术分享图片

 

技术分享图片

 

总结  

    现在再回头看一下 ZWave 的消息队列处理机制,思路非常清晰,而且扩充性非常强。

    后面我希望自己可以抽一点时间,把这里的代码抽取出来,写一个通用的、能够处理一些复杂消息的消息队列机制,让开发过程变得更加愉悦!

 


  1. 欢迎转载,请尊重版权,保留全部内容并注明来源。
  2. 如果这篇文章侵犯了您的权益,请在此处或微信公众号留言,我会及时处理。

  3. 如果需要一块探讨,请联系下面微信公众号技术分享图片



 



以上是关于ZWave 中的消息队列机制的主要内容,如果未能解决你的问题,请参考以下文章

8.windows消息机制消息队列

Android中的Handler机制

消息队列学习一 概念

Linux进程间通信之消息队列

C# 消息队列-MSMQ

Windows 消息机制