2. 程式人生 > >微控制器應用訊息佇列

微控制器應用訊息佇列

阿新 • • 發佈：2018-12-17
  1. #define   u8              unsigned char   
  2. #define   uchar           unsigned char   
  3. #define   u16             unsigned int   
  4. #define   uint            unsigned int   
  5. typedef u8 message;  
  6. //定義訊息  
  7. #define MSG_NONE   0 //無訊息的訊息  
  8. #define MSG_TASK1_RUN   1  
  9. #define MSG_TASK1_STOP  2  
  10. #define MSG_TASK2_RUN   3  
  11. #define MSG_TASK2_STOP  4  
  12. /*=============訊息處理機制定義=================*/  
  13. //定義訊息  
  14. #define  QUEUELEN   5    //訊息佇列緩衝區大小  
  15. u8 Messages[QUEUELEN];   //訊息佇列緩衝區  
  16. u8 MessageHead = 0;      //訊息隊頭  
  17. u8 MessageTail = 0;      //訊息隊尾  
  18. //訊息釋出  
  19. void    PutMessage(message m)  
  20. {  
  21.    Messages[MessageTail] = m ;  
  22.    if(++MessageTail>=QUEUELEN) MessageTail=0;  
  23. }  
  24. //獲取訊息緩衝區的訊息  
  25. message GetMessage(void)  
  26. {  
  27.   message m = Messages[MessageHead];  
  28.   if(++MessageHead>=QUEUELEN) MessageHead=0;  
  29.   return m ;  
  30. }  
  31. //判斷佇列是否空或者錯  
  32. bit     QueueEmptyOrError(void)  
  33. {  
  34.      return (MessageHead==MessageTail)?1:0;  
  35. }  
  36. void main(void)  
  37. {  
  38.   u8 RandTaskGene;  
  39.   while(1)  
  40.   {  
  41.    RandTaskGene = rand();  
  42.    RandTaskGene %=2;  
  43.    if(RandTaskGene)  
  44.    {  
  45.       PutMessage(MSG_TASK1_RUN);  
  46.    }  
  47.    else  
  48.    {  
  49.       PutMessage(MSG_TASK1_STOP);  
  50.    }  
  51.    RandTaskGene = rand();  
  52.    if(RandTaskGene>1000)  
  53.     {  
  54.       PutMessage(MSG_TASK2_RUN);  
  55.     }  
  56.    else  
  57.     {  
  58.       PutMessage(MSG_TASK2_STOP);  
  59.     }  
  60.     while(!QueueEmptyOrError())  
  61.         {  
  62.            switch (GetMessage())  
  63.                {  
  64.                  case MSG_TASK1_RUN:  
  65.                       //...  
  66.                       break;  
  67.                  case MSG_TASK1_STOP:  
  68.                       //...  
  69.                       break;  
  70.                  case MSG_TASK2_RUN:  
  71.                       //...  
  72.                       break;  
  73.                  case MSG_TASK2_RUN:  
  74.                       //...  
  75.                       break;        
  76.                }  
  77.         }  
  78.   }  
  79. }  

相關推薦

微控制器應用訊息佇列

#define   u8              unsigned char    #define   uchar           unsigned char    #define   u16             unsigned int    #define   uint        

Qt應用Redis實現訊息佇列

    類似BS模式，客戶端傳送任務請求給服務端，服務端將處理結果返回給客戶端。 redis負責訊息的儲存和轉發。 模擬病人掛號看病，Patient程序進行掛號，Doctor程序進行看病 ，程式程式碼如下： /////////////

PHP訊息佇列實現及應用：訊息佇列概念介紹

  在網際網路專案開發者經常會遇到『給使用者群發簡訊』、『訂單系統有大量的日誌需要記錄』或者在秒殺業務的時候伺服器無法承受瞬間併發的壓力。  這種情況下，我們怎麼保證系統正常有效的執行呢？ 這個時候，我們可以引入一個叫『訊息佇列』的概念來解決上面的需求。 訊息佇列的概

activeMQ的訂閱者和訊息佇列的應用

1.PTP模型 PTP(Point-to-Point)模型是基於佇列(Queue)的,對於PTP訊息模型而言,它的訊息目的是一個訊息佇列(Queue),訊息生產者每次傳送訊息總是把訊息送入訊息佇列中,訊息消費者總是從訊息佇列中讀取訊息.先進佇列的訊息將先被訊息消費者讀取. 傳送方發訊息到佇列

日誌系統之訊息佇列的應用

kafka的概述 Kakfa是由LinkedIn公司開發的一個分散式的訊息系統，後成為Apache頂級開源專案，它使用Scala編寫，以可水平擴充套件和高吞吐率的特性而被廣泛使用。 ps: 通過上述百度百科的概述，只知其然而不知其所以然。 kafka 大家都知道是訊息佇列，那麼籠統的說訊息佇列是

Kafka訊息佇列介紹、環境搭建及應用：C#實現消費者-生產者訂閱

一：kafka介紹 kafka（官網地址：http://kafka.apache.org）是一種高吞吐量的分散式釋出訂閱的訊息佇列系統，具有高效能和高吞吐率。 1.1 術語介紹 Broker Kafka叢集包含一個或多個伺服器，這種伺服器被稱為broker

RabbitMQ系列之七 分散式訊息佇列應用場景之非同步處理、應用解耦、流量削鋒和訊息通訊理解分析

摘要：訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題。實現高效能，高可用，可伸縮和最終一致性架構。是大型分散式系統不可缺少的中介軟體。 目前在生產環境，使用較多的訊息佇列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，

訊息佇列的應用場景和常見的訊息佇列之間的比較

From: http://blog.csdn.net/cws1214/article/details/52922267 訊息佇列使用的四種場景介紹 訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題 實現高效能，高

java併發包訊息佇列及在開源軟體中的應用

1.BlockingQueue的常用方法 BlockingQueue也是java.util.concurrent下的主要用來控制執行緒同步的工具。 主要的方法是：put、take一對阻塞存取；add、poll一對非阻塞存取。          插入:        1

IPC——應用三 訊息佇列

  目錄 一：訊息佇列 1.1定義 1.2設計方案   1.3知識瞭解 二：程式碼實現 2.1傳送訊息 2.2取用訊息 2.3測試執行   一：訊息佇列 1.1定義      

【圖文詳細 】Kafka訊息佇列——Kafka的應用場景

3.1、訊息系統 Kafka 很好地替代了傳統的 message broker（訊息代理）。Message Brokers 可用於各種場合（如 將資料生成器與資料處理解耦，緩衝未處理的訊息等）。與大多數訊息系統相比，Kafka 擁有 更好的吞吐量、內建分割槽、具有複製和容錯的功能，這使它成為

四種訊息佇列應用場景

原文地址：http://www.cnblogs.com/stopfalling/p/5375492.html 1非同步處理 場景說明：使用者註冊後，需要發註冊郵件和註冊簡訊。傳統的做法有兩種1.序列的方式；2.並行方式。 （1）序列方式：將註冊資訊寫入資料庫成功後，傳送註冊郵件，再發送註

訊息佇列四種應用場景

引用 博文連線，很好的一篇部落格，列舉了訊息佇列的使用場景和場景訊息佇列的基本概念，並貼上了收集的博文資料。 訊息佇列使用場景 　　息佇列基本使用場景有四種，分別是非同步處理、應用解耦、流量削峰和日誌處理等。 　　解耦和非同步處理往往相輔相成，比如兩

訊息佇列常見的 5 個應用場景

一、簡介 訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題。實現高效能、高可用、可伸縮和最終一致性架構。使用較多的訊息佇列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ。 二、訊息佇列應

ActiveMQ訊息佇列的使用及應用（二丶JMS基本概念和模型）

一丶JMS基本概念（1） 概念 JMS Java Message Service，Java訊息服務，是Java EE中的一個技術 JMS規範 JMS 定義了Java中訪問訊息中介軟體的介面，並沒有給予實現，實現JMS介面的訊息中介軟體叫JMS Provider，例如ActiveMQ JMS Prov

ActiveMQ訊息佇列的使用和應用

一、什麼是ActiveMQ AciveMQ是Apache出品的目前最流行，能力強勁的開源訊息匯流排 訊息列隊有兩種訊息模式，一種是點對點的訊息模式，還有一種就是訂閱的模式. 主要功能： 解決伺服器之間的耦合性 使用訊息佇列，增加系統併發處理量 主要應用場景：

RabbitMQ實戰教程(十二):訊息佇列的應用場景

這是網上的一篇教程寫的很好，不知原作者是誰，沒法註明出處，我看的時候也是別人轉載的，這裡就註明一下那篇轉載的地址：http://blog.csdn.net/cws1214/article/details/52922267 訊息佇列中介軟體是分散式系統中

rabbitmq訊息佇列php實際應用

rabbitmq 訊息佇列 php應用 前段時間公司需要用到訊息佇列，就湊時間研究了下rabbitmq，由於本人ubuntu環境，windows應用不確定哈。 程式碼貼出來了，根據自身專案編寫，並不適合所有專案，需要調整自行改動。 1.MQ則是遵循

RabbitMQ訊息佇列在PHP下的應用

訊息佇列的實現中,RabbitMQ以其健壯和可靠見長.公司的專案中選擇了它作為訊息佇列的實現.關於MQ的機制和原理網上有很多文章可以看,這裡就不再贅述,只講幾個比較容易混淆的問題 1,binding key和routing key 　　binding key和routing key是都不過是自己設定的一組字

訊息佇列應用場景

https://www.cnblogs.com/stopfalling/p/5375492.html 1非同步處理 場景說明：使用者註冊後，需要發註冊郵件和註冊簡訊。傳統的做法有兩種1.序列的方式；2.並行方式。 （1）序列方式：將註冊資訊寫入資料庫成功後，傳送註冊郵件，再發送註冊簡訊。