nRF24L01 一傳多問題

xyzll3

大家好
小弟用3個nRF24L01組成系統, 1個當master, 2個當slave
master定時輪流詢問slave(step 1,3), slave收到後回應master(step 2,4)


但是slave總會規律低收不到來自master訊息


有人有成功經驗嗎
研究好久都沒結果
附上程式碼
謝謝

master 程式碼

1. 
   
2. 
   
3. #include <SPI.h>
   
4. #include "RF24.h"
   
5. 
   
6. RF24 rf24(7, 8); // CE腳, CSN腳
   
7. 
   
8. byte pipe = 1;  // 指定通道編號
   
9. const byte addr[][6] = {"1Node","2Node"};
   
10. const byte addr_m_tx[][6] = {"1MOSI", "2MOSI"};     
    
11. const byte addr_s_tx[][6] = {"1MISO", "2MISO"};     
    
12. const char msg1[] = "1 Happy Hacking!";
    
13. const char msg2[] = "2 Happy Hacking!";
    
14. unsigned long started_waiting_at;
    
15. 
    
16. void setup() {
    
17.   Serial.begin(9600);
    
18.   rf24.begin();
    
19.   rf24.setChannel(83);                      // 設定頻道編號
    
20.   rf24.openWritingPipe(addr_m_tx[0]);       // 設定1Node通道位址   
    
21.   rf24.openReadingPipe(pipe, addr_s_tx[0]); // 設定1Node通道位址   
    
22.   rf24.setPALevel(RF24_PA_MIN);             // 設定廣播功率
    
23.   rf24.setDataRate(RF24_2MBPS);             // 設定傳輸速率
    
24.   rf24.stopListening();                     // 停止偵聽；設定成發射模式
    
25.   Serial.println("nRF24L01 master ready!");
    
26. }
    
27. 
    
28. void loop() {
    
29. 
    
30.   rf24.openWritingPipe(addr_m_tx[0]);       // 設定1Node通道位址
    
31.   rf24.openReadingPipe(pipe, addr_s_tx[0]); // 設定1Node通道位址     
    
32.   rf24.write(&msg1, sizeof(msg1));  // 傳送資料
    
33. 
    
34. #if 1
    
35.   rf24.startListening();
    
36.   started_waiting_at = micros();
    
37.   
    
38.   while(1)
    
39.   {
    
40.     //if(rf24.available(&pipe))
    
41.     if(rf24.available())
    
42.     {
    
43.        char msg[32] = "";
    
44.        rf24.read(&msg, sizeof(msg));
    
45.        Serial.println(msg); // 顯示訊息內容
    
46.        break;  
    
47.     }
    
48.    
    
49.     if(micros() - started_waiting_at > 100000)    //If waited longer than 100ms, indicate timeout and exit while loop
    
50.     {
    
51.       Serial.println("Timeout");
    
52.       break;
    
53.     }
    
54.   }
    
55.   
    
56.   rf24.stopListening();
    
57. #endif
    
58. 
    
59. 
    
60.   delay(1000);
    
61.   rf24.openWritingPipe(addr_m_tx[1]);       // 設定2Node通道位址
    
62.   rf24.openReadingPipe(pipe, addr_s_tx[1]); // 設定2Node通道位址  
    
63.   rf24.write(&msg2, sizeof(msg2));  // 傳送資料
    
64. 
    
65. #if 1
    
66.   rf24.startListening();
    
67.   started_waiting_at = micros();
    
68. 
    
69.   while(1)
    
70.   {
    
71.     //if(rf24.available(&pipe))
    
72.     if(rf24.available())
    
73.     {
    
74.        char msg[32] = "";
    
75.        rf24.read(&msg, sizeof(msg));               
    
76.        Serial.println(msg); // 顯示訊息內容
    
77.        break;  
    
78.     }
    
79.   
    
80.     if(micros() - started_waiting_at > 100000)    //If waited longer than 100ms, indicate timeout and exit while loop
    
81.     {
    
82.       Serial.println("Timeout");
    
83.       break;
    
84.     }
    
85.   }
    
86.   
    
87. #endif
    
88.   rf24.stopListening();
    
89. 
    
90.   delay(1000);
    
91. }

複製代碼

slave1 程式碼

1. 
   
2. 
   
3. #include <SPI.h>
   
4. #include "RF24.h"
   
5. 
   
6. RF24 rf24(7, 8); // CE腳, CSN腳
   
7. 
   
8. byte pipe = 1;  // 指定通道編號
   
9. const byte addr_m_tx[6] = "1MOSI";     
   
10. const byte addr_s_tx[6] = "1MISO";     
    
11. const char ack_msg[] = "Slave1 ack";
    
12. 
    
13. void setup() {
    
14.   Serial.begin(9600);
    
15.   rf24.begin();
    
16.   rf24.setChannel(83);  // 設定頻道編號
    
17.   rf24.setPALevel(RF24_PA_MIN);
    
18.   rf24.setDataRate(RF24_2MBPS);
    
19.   rf24.openWritingPipe(addr_s_tx);      // 設定1Node通道位址   
    
20.   rf24.openReadingPipe(pipe,addr_m_tx); // 設定1Node通道位址
    
21.   
    
22.   rf24.startListening();  // 開始監聽無線廣播
    
23.   Serial.println("nRF24L01 slave1 ready!");
    
24. }
    
25. 
    
26. void loop() {
    
27.   if (rf24.available(&pipe)) {
    
28.     char msg[32] = "";
    
29.     rf24.read(&msg, sizeof(msg));
    
30.     Serial.println(msg); // 顯示訊息內容
    
31.     rf24.stopListening();
    
32.     rf24.write( &ack_msg, sizeof(ack_msg) );
    
33.     rf24.startListening();   
    
34.   }
    
35. }

複製代碼

slave2 程式碼

1. 
   
2. 
   
3. #include <SPI.h>
   
4. #include "RF24.h"
   
5. 
   
6. RF24 rf24(7, 8); // CE腳, CSN腳
   
7. 
   
8. byte pipe = 1;  // 指定通道編號
   
9. const byte addr_m_tx[6] = "2MOSI";     
   
10. const byte addr_s_tx[6] = "2MISO";     
    
11. const char ack_msg[] = "Slave2 ack";
    
12. 
    
13. void setup() {
    
14.   Serial.begin(9600);
    
15.   rf24.begin();
    
16.   rf24.setChannel(83);  // 設定頻道編號
    
17.   rf24.setPALevel(RF24_PA_MIN);
    
18.   rf24.setDataRate(RF24_2MBPS);
    
19.   rf24.openWritingPipe(addr_s_tx);      // 設定2Node通道位址   
    
20.   rf24.openReadingPipe(pipe,addr_m_tx); // 設定2Node通道位址  
    
21.   
    
22.   rf24.startListening();  // 開始監聽無線廣播
    
23.   Serial.println("nRF24L01 slave ready!");
    
24. }
    
25. 
    
26. void loop() {
    
27.   if (rf24.available(&pipe)) {
    
28.     char msg[32] = "";
    
29.     rf24.read(&msg, sizeof(msg));
    
30.     Serial.println(msg); // 顯示訊息內容
    
31.     rf24.stopListening();
    
32.     rf24.write( &ack_msg, sizeof(ack_msg) );
    
33.     rf24.startListening();   
    
34.   }
    
35. }

複製代碼

超新手

把 程式 TIMEOUT 時間加長
或是
SLAVE 端 調過來看   
原來

1. 
   
2.     Serial.println(msg); // 顯示訊息內容
   
3.     rf24.stopListening();
   
4.     rf24.write( &ack_msg, sizeof(ack_msg) );
   
5.     rf24.startListening();
   

複製代碼

改成

1. 
   
2.     rf24.stopListening();
   
3.     rf24.write( &ack_msg, sizeof(ack_msg) );
   
4.     rf24.startListening();
   
5.     Serial.println(msg); // 顯示訊息內容
   

複製代碼

xyzll3

嗨，更新一下狀況
我後來排除timeout值太短或serial.println造成延遲的關係

後來方法是master在timeout的時候再重傳一次資料
這樣就能收到slave回應

master 程式碼

1. 
   
2. 
   
3. #include <SPI.h>
   
4. #include "RF24.h"
   
5. 
   
6. RF24 rf24(7, 8); // CE腳, CSN腳
   
7. 
   
8. byte pipe = 1;  // 指定通道編號
   
9. const byte addr[][6] = {"1Node","2Node"};
   
10. const byte addr_m_tx[][6] = {"1MOSI", "2MOSI"};     
    
11. const byte addr_s_tx[][6] = {"1MISO", "2MISO"};     
    
12. const char msg1[] = "1 Happy Hacking!";
    
13. const char msg2[] = "2 Happy Hacking!";
    
14. unsigned long started_waiting_at;
    
15. 
    
16. void setup() {
    
17.   Serial.begin(115200);
    
18.   rf24.begin();
    
19.   rf24.setChannel(83);                      // 設定頻道編號
    
20.   //rf24.openWritingPipe(addr_m_tx[0]);       // 設定1Node通道位址   
    
21.   //rf24.openReadingPipe(pipe, addr_s_tx[0]); // 設定1Node通道位址   
    
22.   rf24.setPALevel(RF24_PA_MIN);             // 設定廣播功率
    
23.   rf24.setDataRate(RF24_2MBPS);             // 設定傳輸速率
    
24.   rf24.stopListening();                     // 停止偵聽；設定成發射模式
    
25.   Serial.println("nRF24L01 master ready!");
    
26. }
    
27. 
    
28. void loop() {
    
29. 
    
30.   delay(1000);
    
31. 
    
32.   
    
33.   rf24.openWritingPipe(addr_m_tx[0]);       // 設定1Node通道位址
    
34.   rf24.openReadingPipe(pipe, addr_s_tx[0]); // 設定1Node通道位址     
    
35.   rf24.write(&msg1, sizeof(msg1));  // 傳送資料
    
36. 
    
37. #if 1
    
38.   rf24.startListening();
    
39.   started_waiting_at = micros();
    
40.   
    
41.   while(1)
    
42.   {
    
43.     //if(rf24.available(&pipe))
    
44.     if(rf24.available())
    
45.     {
    
46.        char msg[32] = "";
    
47.        rf24.read(&msg, sizeof(msg));
    
48.        Serial.println(msg); // 顯示訊息內容
    
49.        break;  
    
50.     }
    
51.    
    
52.     if(micros() - started_waiting_at > 300000)    //If waited longer than 100ms, indicate timeout and exit while loop
    
53.     {
    
54.       rf24.stopListening();
    
55.       rf24.write(&msg1, sizeof(msg1));  // 重傳資料
    
56.       rf24.startListening();
    
57.       started_waiting_at = micros();
    
58.       Serial.println("Resend 1");
    
59.     }
    
60.   }
    
61.   
    
62.   rf24.stopListening();
    
63. #endif
    
64. 
    
65.   delay(1000);
    
66.   rf24.openWritingPipe(addr_m_tx[1]);       // 設定2Node通道位址
    
67.   rf24.openReadingPipe(pipe, addr_s_tx[1]); // 設定2Node通道位址  
    
68.   rf24.write(&msg2, sizeof(msg2));  // 傳送資料
    
69. 
    
70. #if 1
    
71.   rf24.startListening();
    
72.   started_waiting_at = micros();
    
73. 
    
74.   while(1)
    
75.   {
    
76.     //if(rf24.available(&pipe))
    
77.     if(rf24.available())
    
78.     {
    
79.        char msg[32] = "";
    
80.        rf24.read(&msg, sizeof(msg));               
    
81.        Serial.println(msg); // 顯示訊息內容
    
82.        break;  
    
83.     }
    
84.   
    
85.     if(micros() - started_waiting_at > 300000)    //If waited longer than 100ms, indicate timeout and exit while loop
    
86.     {
    
87.       rf24.stopListening();
    
88.       rf24.write(&msg2, sizeof(msg2));  // 重傳資料
    
89.       rf24.startListening();
    
90.       started_waiting_at = micros();
    
91.       Serial.println("Resend 2");
    
92.     }
    
93.   }
    
94.   
    
95. #endif
    
96.   rf24.stopListening();
    
97. 
    
98. }

複製代碼

不過不清楚為什麼一定要重傳一次
印像中SPI需要dummy data，會不會有關呢
還請熟悉SPI高手解惑