Bir önceki yazıda ESP8266 ile MQTT protokolünün kullanımı anlatmıştım. Bu yazıda ise benzer şekilde MQTT protokolünü SIM800 serisi bir GSM/GPRS modülü ile kullanalım ve STM32‘nin abone olduğu bir topice gelen mesaja göre basitçe bir led yakma söndürme işlemini yapalım. Bu yazıyı bir önceki yazının devamı olarak düşünebiliriz
Bir önceki yazının sonlarında bahsettiğim port yönlendirme olayını bu yazıda yapacağız. ESP8266 ve brokerın çalıştığı bilgisayar aynı Wi-Fi ağına bağlı olduğu için port yönlendirme yapmamıştım. GSM modülü GPRS bağlantısı ile brokera dışarıdan bağlanacak yani aynı ağ içerisinde olmayacağı için port yönlendirme yapmamız gerekir. Port yönlendirmeyi modem arayüzünden “NAT” sekmesinden yapabilirsiniz.
Yukarıdaki resimde benim port yönlendirme için yaptığım ayarlar görülmektedir. Yerel IP adresi brokerın çalıştığı bilgisayarın IP numarası olmalı ve port yine 1883 olmalı.
Port yönlendirme ayarlarını yaptıktan sonra brokerı çalıştırıp port yönlendirme işleminin yapılıp yapılmadığını kontrol etmekte fayda var. Bunun için bazı siteler var. Mesela canyouseeme.org sitesine giderseniz karşınıza aşağıdaki gibi bir sayfa çıkacak.
Bu siteden portun açık olup olmadığını kontrol edebilirsiniz. Buradaki IP numarası sizin internetinizin IP numarasıdır. Bu IP numarasını brokera bağlanırken kullanacağız.
NOT: Burada değinmek istediğim önemli bir nokta var. Bazı internet sağlayıcı firmalar havuz IP sistemine geçmiş. Bu yüzden siz port açsanız bile dışarıdan o porta erişemiyorsunuz. Porta erişebilmek için statik IP almak gerekiyor ve bununda aylık belli bir ücreti var.Ben 1883 portuna erişmek için uzunca bir zaman harcamıştım.Sonradan öğrendim ki internet sağlayıcımdan kaynaklanan bir sorunmuş. Eğer sizde açtığınız porta dışarıdan erişemiyorsanız bu yüzden olabilir.
Brokera Bağlanma
MQTT paket formatının detaylarına bir önceki yazıda değinmiştim. Bir önceki yazıya ulaşmak için burayı tıklayabilirsiniz ->ESP8266 ve STM32 ile MQTT Protokolünün Kullanımı
Kullanacağımız MQTT paket formatlarını hatırlayalım.
Brokera bağlanmak için yazdığım fonksiyon aşağıdaki gibidir. Paket formatının içeriği değişmediği için bu fonksiyondaki değişiklikler sadece AT komutlarında yapılmıştır.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 | void Connect_Broker(char *Ip ,char *Port) { HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPCLOSE\r\n",strlen("AT+CIPCLOSE\r\n"),1000); // Close TCP or UDP connection. HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPMODE=0\r\n",strlen("AT+CIPMODE=0\r\n"),5000); // TCP Application Mode : 0->Normal Mode ,1->Transparent Mode HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPMUX=0\r\n",strlen("AT+CIPMUX=0\r\n"),1000); // Single IP connection HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CSTT=\"internet\",\"\",\"\"\r\n",strlen("AT+CSTT=\"internet\",\"\",\"\"\r\n"),5000); // APN settings HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIICR\r\n",strlen("AT+CIICR\r\n"),5000); // Bring Up Wireless Connection with GPRS or CSD HAL_Delay(1000); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIFSR\r\n",strlen("AT+CIFSR\r\n"),1000); // Get Local IP Address HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSTART=\"TCP\",\"%s\",\"%s\"\r\n",Ip,Port),5000); // Start up TCP connection HAL_Delay(2000); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPQSEND=1\r\n",strlen("AT+CIPQSEND=1\r\n"),5000); // Select Data Transmitting Mode. 0->Normal mode ,1->Quick send mode HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"ATE0\r\n",strlen("ATE0\r\n"),5000); // Set Command Echo Mode. 0->Echo mode off,1->Echo mode on HAL_Delay(100); //connect packet ProtocolNameLength = strlen(protocolName); ClientIDLength = strlen(clientID); uint8_t Remainlength; Remainlength = 2+ProtocolNameLength+6+ClientIDLength; uint16_t length = sprintf(tx_buffer,"%c%c%c%c%s%c%c%c%c%c%c%s",(char)connect,(char)Remainlength,(char)(ProtocolNameLength << 8),(char)ProtocolNameLength,protocolName,(char)level,(char)flag,(char)(keepAlive << 8),(char)keepAlive,(char)(ClientIDLength << 8),(char)ClientIDLength,clientID); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSEND=%d\r\n",length),1000); HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"%c%c%c%c%s%c%c%c%c%c%c%s",(char)connect,(char)Remainlength,(char)(ProtocolNameLength << 8),(char)ProtocolNameLength,protocolName,(char)level,(char)flag,(char)(keepAlive << 8),(char)keepAlive,(char)(ClientIDLength << 8),(char)ClientIDLength,clientID),5000); } |
Bu fonksiyonda ESP8266 için yazılan fonksiyona göre bir kaç farklılıklar ve ekstradan AT komutları var. Bunlara biraz değinelim.
AT+CSTT=”internet”,””,”” : Bu komut ile APN ayarlarını yapıyoruz. Ben GSM modüle Turkcell simkart taktığım için APN ayarlarını bu şekilde yaptım.
AT+CIICR: GPRS bağlantısı kurmak veya aktif etmek için bu komutu kullanıyoruz.
AT+CIPSTART=”TCP”,”212.125.xx.xxx”,”1883″: Bu komut ESP8266 da kullanılan TCP/IP bağlantı komutuna benzesede gözden kaçan ufak bir farklılık var. ESP8266 için kullanılan komutta port bilgisi çift tırnak işareti olmadan gönderiliyor. SIM800 modülü için ise port değeri de çift tırnak arasında olması gerekli. Ayrıca buradaki IP adresi yukarıda bahsettiğim canyouseeme.org sitesinde görülen sizin internetinizin IP adresi olmalı.
ATE0: Bu tarz AT komutları ile haberleşen modüllerde eko(echo) olarak adlandırılan bir durum vardır. Siz uart üzerinden modüle gönderdiğiniz komutu GSM modül işlemeden önce sizin gönderdiğiniz mesajı aynen size geri iletir. Subscribe olduğumuz topice gelen mesaj da yine uart üzerinden STM32’ye geleceği için rx_buffer’da gönderdiğim verilerin tekrar kaydedilmesini istemediğim için echo modunu pasif ediyorum(ATE0->Echo mode off,ATE1->Echo mode on).
Subscribe ile Publish fonksiyonlarında bir değişiklik yapmadım.
1 2 3 4 5 6 7 8 9 10 | void Subscribe(char *topic) { uint16_t TopicLength = strlen(topic); uint8_t RemainLength = 2+2+TopicLength+1; // packetIDlength(2) + topiclengthdata(2)+topiclength+Qos uint16_t length = sprintf(tx_buffer,"%c%c%c%c%c%c%s%c",(char)subscribeCon,(char)RemainLength,(char)(packetID << 8),(char)packetID,(char)(TopicLength << 8),(char)TopicLength,topic,(char)Qos); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSEND=%d\r\n",length),1000); HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"%c%c%c%c%c%c%s%c",(char)subscribeCon,(char)RemainLength,(char)(packetID << 8),(char)packetID,(char)(TopicLength << 8),(char)TopicLength,topic,(char)Qos),5000); } |
1 2 3 4 5 6 7 8 9 10 11 12 | void publish(char *topic, char *message) { uint16_t topiclength = strlen(topic); uint8_t remainlength = 2+topiclength+strlen(message); int length = sprintf(tx_buffer,"%c%c%c%c%s%s",(char)publishCon,(char)remainlength,(char)(topiclength << 8),(char)topiclength,topic,message); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSEND=%d\r\n",length),100); HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"%c%c%c%c%s%s",(char)publishCon,(char)remainlength,(char)(topiclength << 8),(char)topiclength,topic,message),5000); HAL_Delay(100); } |
MQTT ile Basitçe Bir LED Yakma/Söndürme
Son olarak STM32‘ye bağlı bir ledi MQTT protokolünü kullanarak yakıp söndürme işleminden bahsetmek istiyorum. Bu işlemi şöyle yapacağız; STM32 ile “IOT” topic’ine abone olacağız ve telefona daha önce indirdiğim MyMQTT isimli uygulamadan bu topic’e basitçe bir mesaj gönderip(ON veya OFF) led yakıp söndüreceğiz. Kolay anlaşılması açısından olabildiğince olayı basite indirmeye çalışacağım. Mantığını anladığınız zaman istediğiniz gibi mesaj gönderip led yakıp söndürmekten daha farklı işlemleri yapabilirsiniz.
Peki subsribe olunan topice bir mesaj geldiğinde STM32’ye uart üzerinden nasıl veriler gelir? Şöyle düşünelim; Telefondan veya başka bir bilgisayardan bir topice mesaj gönderdiğimizde yani yayın(publish) yaptığımızda belli paket formatında veriler gönderiyorduk. Aynı şekilde STM32 ile yayın yaparken de bu formatı uart üzerinden göndererek yayın yapıyorduk. Burada aslında yayını biz broker’a yapıyoruz ve broker bizim yayın yaptığımız topice abone olan başka bir cihaz var ise aynı şekilde broker da o cihazlara yayın yapıyor. Yani kısaca STM32 ile abone olduğumuz topice bir mesaj geldiğinde publish paket formatının aynısı uart üzerinden STM32’ye gelmesi gerekir.
Bu paketin içerisinden mesajı verisini çekip buna göre bir karar mekanizması kurmamız gerekir. Bu mesajı çekmek için basitçe şöyle bir algoritma kullandım.
- Buffer içerisinde publish paket formatın başlangıç değeri(0x30) bir for döngüsü ile aranıp bu değişkenin buffer içerisindeki yeri saptanır.
- Daha sonra 0x30 değerinden sonraki 3 değer okunup topic adı uzunluğu ve remain length çekilir.
- message_length = remain_length -(topic_length + 2) ile okunacak olan mesaj uzunluğu hesaplanır.
- Bir başka for döngüsü ile mesaj bir başka diziye kaydedilir.
Mesajı çeknek için yazdığım fonksiyon aşağıdaki gibidir.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 | void Read_Message() { int remain_length=0,message_length=0,topic_length=0; char message[100]; HAL_UART_AbortReceive_IT(&huart1); for(int i=0;i<sizeof(rx_buffer);i++) { if(rx_buffer[i] == 0x30) { remain_length = rx_buffer[i+1]; topic_length = rx_buffer[i+2]+rx_buffer[i+3]; message_length = remain_length -(topic_length + 2); for(int j=0;j<message_length;j++) { message[j] = rx_buffer[i+4+topic_length+j]; } break; } } if(message[0] == 'O' && message[1] == 'N') { HAL_GPIO_WritePin(GPIOC,GPIO_PIN_13,GPIO_PIN_RESET); // turn led on (C13) publish("LED","LED ON"); } if(message[0] == 'O' && message[1] == 'F' && message[2] == 'F') { HAL_GPIO_WritePin(GPIOC,GPIO_PIN_13,GPIO_PIN_SET); // turn led off publish("LED","LED OFF"); } memset(rx_buffer,0,sizeof(rx_buffer)); // clear buffer memset(message,0,sizeof(message)); HAL_UART_Receive_IT(&huart1,(uint8_t *)rx_buffer,100); } |
Bu fonksiyonun içine her komut geldiğinde değişikliği LED isimliği topice gönderecek şekilde publish fonksiyonunu ekledim. Son olarak memset fonksiyonu ile rx_buffer ve message dizilerini sıfırladım. Mesajı çekmek için kullandığım bu fonksiyonu sonsuz döngü içerisinde aşağıdaki gibi kullandım.
1 2 3 4 5 6 7 8 9 10 11 | while (1) { Read_Message(); HAL_Delay(500); /* USER CODE END WHILE */ /* USER CODE BEGIN 3 */ } |
Aşağıda MyMQTT ile gönderdiğim komutlara karşılık gelen cevapların ekran görüntülerini ekledim.
STM32 Kodlarının Tamamı
Proje dosyasını Github‘tan indirmek için buraya tıklayabilirsiniz.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 | /** ****************************************************************************** * @file : main.c * @brief : Main program body ****************************************************************************** ** This notice applies to any and all portions of this file * that are not between comment pairs USER CODE BEGIN and * USER CODE END. Other portions of this file, whether * inserted by the user or by software development tools * are owned by their respective copyright owners. * * COPYRIGHT(c) 2020 STMicroelectronics * * Redistribution and use in source and binary forms, with or without modification, * are permitted provided that the following conditions are met: * 1. Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * 3. Neither the name of STMicroelectronics nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * ****************************************************************************** */ /* Includes ------------------------------------------------------------------*/ #include "main.h" #include "stm32f1xx_hal.h" /* USER CODE BEGIN Includes */ #include "string.h" /* USER CODE END Includes */ /* Private variables ---------------------------------------------------------*/ UART_HandleTypeDef huart1; /* USER CODE BEGIN PV */ /* Private variables ---------------------------------------------------------*/ char rx_buffer[100],tx_buffer[150]; uint16_t ProtocolNameLength; uint16_t ClientIDLength; uint8_t connect = 0x10,publishCon = 0x30,subscribeCon = 0x82; char *protocolName = "MQTT"; uint8_t level = 0x04; uint8_t flag = 0x02; // 02--> sifresiz uint16_t keepAlive =60; uint16_t packetID = 0x01; uint8_t Qos = 0x00; char *clientID = "Topuz"; /* USER CODE END PV */ /* Private function prototypes -----------------------------------------------*/ void SystemClock_Config(void); static void MX_GPIO_Init(void); static void MX_USART1_UART_Init(void); /* USER CODE BEGIN PFP */ /* Private function prototypes -----------------------------------------------*/ void Connect_Broker(char *Ip ,char *Port) { HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPCLOSE\r\n",strlen("AT+CIPCLOSE\r\n"),1000); // Close TCP or UDP connection. HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPMODE=0\r\n",strlen("AT+CIPMODE=0\r\n"),5000); // TCP Application Mode : 0->Normal Mode ,1->Transparent Mode HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPMUX=0\r\n",strlen("AT+CIPMUX=0\r\n"),1000); // Single IP connection HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CSTT=\"internet\",\"\",\"\"\r\n",strlen("AT+CSTT=\"internet\",\"\",\"\"\r\n"),5000); // APN settings HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIICR\r\n",strlen("AT+CIICR\r\n"),5000); // Bring Up Wireless Connection with GPRS or CSD HAL_Delay(1000); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIFSR\r\n",strlen("AT+CIFSR\r\n"),1000); // Get Local IP Address HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSTART=\"TCP\",\"%s\",\"%s\"\r\n",Ip,Port),5000); // Start up TCP connection HAL_Delay(2000); HAL_UART_Transmit(&huart1,(uint8_t *)"AT+CIPQSEND=1\r\n",strlen("AT+CIPQSEND=1\r\n"),5000); // Select Data Transmitting Mode. 0->Normal mode ,1->Quick send mode HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)"ATE0\r\n",strlen("ATE0\r\n"),5000); // Set Command Echo Mode. 0->Echo mode off,1->Echo mode on HAL_Delay(100); //connect packet ProtocolNameLength = strlen(protocolName); ClientIDLength = strlen(clientID); uint8_t Remainlength; Remainlength = 2+ProtocolNameLength+6+ClientIDLength; uint16_t length = sprintf(tx_buffer,"%c%c%c%c%s%c%c%c%c%c%c%s",(char)connect,(char)Remainlength,(char)(ProtocolNameLength << 8),(char)ProtocolNameLength,protocolName,(char)level,(char)flag,(char)(keepAlive << 8),(char)keepAlive,(char)(ClientIDLength << 8),(char)ClientIDLength,clientID); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSEND=%d\r\n",length),1000); HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"%c%c%c%c%s%c%c%c%c%c%c%s",(char)connect,(char)Remainlength,(char)(ProtocolNameLength << 8),(char)ProtocolNameLength,protocolName,(char)level,(char)flag,(char)(keepAlive << 8),(char)keepAlive,(char)(ClientIDLength << 8),(char)ClientIDLength,clientID),5000); } void Subscribe(char *topic) { uint16_t TopicLength = strlen(topic); uint8_t RemainLength = 2+2+TopicLength+1; // packetIDlength(2) + topiclengthdata(2)+topiclength+Qos uint16_t length = sprintf(tx_buffer,"%c%c%c%c%c%c%s%c",(char)subscribeCon,(char)RemainLength,(char)(packetID << 8),(char)packetID,(char)(TopicLength << 8),(char)TopicLength,topic,(char)Qos); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSEND=%d\r\n",length),1000); HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"%c%c%c%c%c%c%s%c",(char)subscribeCon,(char)RemainLength,(char)(packetID << 8),(char)packetID,(char)(TopicLength << 8),(char)TopicLength,topic,(char)Qos),5000); } void publish(char *topic, char *message) { uint16_t topiclength = strlen(topic); uint8_t remainlength = 2+topiclength+strlen(message); int length = sprintf(tx_buffer,"%c%c%c%c%s%s",(char)publishCon,(char)remainlength,(char)(topiclength << 8),(char)topiclength,topic,message); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"AT+CIPSEND=%d\r\n",length),100); HAL_Delay(100); HAL_UART_Transmit(&huart1,(uint8_t *)tx_buffer,sprintf(tx_buffer,"%c%c%c%c%s%s",(char)publishCon,(char)remainlength,(char)(topiclength << 8),(char)topiclength,topic,message),5000); HAL_Delay(100); } void Read_Message() { int remain_length=0,message_length=0,topic_length=0; char message[100]; HAL_UART_AbortReceive_IT(&huart1); for(int i=0;i<sizeof(rx_buffer);i++) { if(rx_buffer[i] == 0x30) { remain_length = rx_buffer[i+1]; topic_length = rx_buffer[i+2]+rx_buffer[i+3]; message_length = remain_length -(topic_length + 2); for(int j=0;j<message_length;j++) { message[j] = rx_buffer[i+4+topic_length+j]; } break; } } if(message[0] == 'O' && message[1] == 'N') { HAL_GPIO_WritePin(GPIOC,GPIO_PIN_13,GPIO_PIN_RESET); // turn led on (C13) publish("LED","LED ON"); } if(message[0] == 'O' && message[1] == 'F' && message[2] == 'F') { HAL_GPIO_WritePin(GPIOC,GPIO_PIN_13,GPIO_PIN_SET); // turn led off publish("LED","LED OFF"); } memset(rx_buffer,0,sizeof(rx_buffer)); // clear buffer memset(message,0,sizeof(message)); HAL_UART_Receive_IT(&huart1,(uint8_t *)rx_buffer,100); } /* USER CODE END PFP */ /* USER CODE BEGIN 0 */ /* USER CODE END 0 */ /** * @brief The application entry point. * * @retval None */ int main(void) { /* USER CODE BEGIN 1 */ /* USER CODE END 1 */ /* MCU Configuration----------------------------------------------------------*/ /* Reset of all peripherals, Initializes the Flash interface and the Systick. */ HAL_Init(); /* USER CODE BEGIN Init */ /* USER CODE END Init */ /* Configure the system clock */ SystemClock_Config(); /* USER CODE BEGIN SysInit */ /* USER CODE END SysInit */ /* Initialize all configured peripherals */ MX_GPIO_Init(); MX_USART1_UART_Init(); /* USER CODE BEGIN 2 */ /* USER CODE END 2 */ /* Infinite loop */ /* USER CODE BEGIN WHILE */ HAL_GPIO_WritePin(GPIOC,GPIO_PIN_13,GPIO_PIN_SET); HAL_UART_Receive_IT(&huart1,(uint8_t *)rx_buffer,100); HAL_Delay(1000); Connect_Broker("212.125.XX.XXX","1883"); // Broker IP and port HAL_Delay(1000); Subscribe("IOT"); HAL_Delay(100); while (1) { Read_Message(); HAL_Delay(500); /* USER CODE END WHILE */ /* USER CODE BEGIN 3 */ } /* USER CODE END 3 */ } /** * @brief System Clock Configuration * @retval None */ void SystemClock_Config(void) { RCC_OscInitTypeDef RCC_OscInitStruct; RCC_ClkInitTypeDef RCC_ClkInitStruct; /**Initializes the CPU, AHB and APB busses clocks */ RCC_OscInitStruct.OscillatorType = RCC_OSCILLATORTYPE_HSE; RCC_OscInitStruct.HSEState = RCC_HSE_ON; RCC_OscInitStruct.HSEPredivValue = RCC_HSE_PREDIV_DIV1; RCC_OscInitStruct.HSIState = RCC_HSI_ON; RCC_OscInitStruct.PLL.PLLState = RCC_PLL_ON; RCC_OscInitStruct.PLL.PLLSource = RCC_PLLSOURCE_HSE; RCC_OscInitStruct.PLL.PLLMUL = RCC_PLL_MUL9; if (HAL_RCC_OscConfig(&RCC_OscInitStruct) != HAL_OK) { _Error_Handler(__FILE__, __LINE__); } /**Initializes the CPU, AHB and APB busses clocks */ RCC_ClkInitStruct.ClockType = RCC_CLOCKTYPE_HCLK|RCC_CLOCKTYPE_SYSCLK |RCC_CLOCKTYPE_PCLK1|RCC_CLOCKTYPE_PCLK2; RCC_ClkInitStruct.SYSCLKSource = RCC_SYSCLKSOURCE_PLLCLK; RCC_ClkInitStruct.AHBCLKDivider = RCC_SYSCLK_DIV1; RCC_ClkInitStruct.APB1CLKDivider = RCC_HCLK_DIV2; RCC_ClkInitStruct.APB2CLKDivider = RCC_HCLK_DIV1; if (HAL_RCC_ClockConfig(&RCC_ClkInitStruct, FLASH_LATENCY_2) != HAL_OK) { _Error_Handler(__FILE__, __LINE__); } /**Configure the Systick interrupt time */ HAL_SYSTICK_Config(HAL_RCC_GetHCLKFreq()/1000); /**Configure the Systick */ HAL_SYSTICK_CLKSourceConfig(SYSTICK_CLKSOURCE_HCLK); /* SysTick_IRQn interrupt configuration */ HAL_NVIC_SetPriority(SysTick_IRQn, 0, 0); } /* USART1 init function */ static void MX_USART1_UART_Init(void) { huart1.Instance = USART1; huart1.Init.BaudRate = 9600; huart1.Init.WordLength = UART_WORDLENGTH_8B; huart1.Init.StopBits = UART_STOPBITS_1; huart1.Init.Parity = UART_PARITY_NONE; huart1.Init.Mode = UART_MODE_TX_RX; huart1.Init.HwFlowCtl = UART_HWCONTROL_NONE; huart1.Init.OverSampling = UART_OVERSAMPLING_16; if (HAL_UART_Init(&huart1) != HAL_OK) { _Error_Handler(__FILE__, __LINE__); } } /** Configure pins as * Analog * Input * Output * EVENT_OUT * EXTI */ static void MX_GPIO_Init(void) { GPIO_InitTypeDef GPIO_InitStruct; /* GPIO Ports Clock Enable */ __HAL_RCC_GPIOC_CLK_ENABLE(); __HAL_RCC_GPIOD_CLK_ENABLE(); __HAL_RCC_GPIOA_CLK_ENABLE(); /*Configure GPIO pin Output Level */ HAL_GPIO_WritePin(GPIOC, GPIO_PIN_13, GPIO_PIN_RESET); /*Configure GPIO pin : PC13 */ GPIO_InitStruct.Pin = GPIO_PIN_13; GPIO_InitStruct.Mode = GPIO_MODE_OUTPUT_PP; GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_LOW; HAL_GPIO_Init(GPIOC, &GPIO_InitStruct); } /* USER CODE BEGIN 4 */ /* USER CODE END 4 */ /** * @brief This function is executed in case of error occurrence. * @param file: The file name as string. * @param line: The line in file as a number. * @retval None */ void _Error_Handler(char *file, int line) { /* USER CODE BEGIN Error_Handler_Debug */ /* User can add his own implementation to report the HAL error return state */ while(1) { } /* USER CODE END Error_Handler_Debug */ } #ifdef USE_FULL_ASSERT /** * @brief Reports the name of the source file and the source line number * where the assert_param error has occurred. * @param file: pointer to the source file name * @param line: assert_param error line source number * @retval None */ void assert_failed(uint8_t* file, uint32_t line) { /* USER CODE BEGIN 6 */ /* User can add his own implementation to report the file name and line number, tex: printf("Wrong parameters value: file %s on line %d\r\n", file, line) */ /* USER CODE END 6 */ } #endif /* USE_FULL_ASSERT */ /** * @} */ /** * @} */ /************************ (C) COPYRIGHT STMicroelectronics *****END OF FILE****/ |
Yazıda yanlış bir bilgi veya gözden kaçırdığım eksik bir şey varsa yorumlarda belirtiniz.
İyi Çalışmalar…
Ellerinize sağlık güzel bir yazı olmuş.
Teşekkürler.
Merhaba. Bir öğrenci olarak yazılarınızdan çok faydalanıyorum. 2 sorum var. ESP8266’nın wifi ya da mqtt broker bağlantısı kopunca while loop içinde tekrar nasıl bağlanabilirim? Ayrıca Read_message fonksiyonunu delay olmadan interrupt ile nasıl çalıştırabilirim? HAL_UART_RxCpltCallback() içinde yazdım ama çalışmadı nedense.
1-) MQTT de “ping request” paketi var bu paketi server’a gönderdiğinizde size “ping response” paketini gönderir. Keep alive süresi 60 ise siz her 50 saniye de bir servera ping request paketini gönderirseniz server-client bağlantısı kesilmeyecektir. Eğer ping request e cevap olarak ping response paketini göndermiyorsa server ile bağlantınız kopmuş demektir. Yani serverın ping requeste gönderdiği cevabı güzelce okuyup server bağlantısının olup olmadığına dair bir kontrol mekanizması kurmanız gerek. Bu aşamadan sonra eğer bağlantı kesilmiş ise tekrar Connect_Broker ve subscribe fonksiyonlarını sırasıyla tekrar çağırmalısınız.
2-) HAL_UART_RxCpltCallback() fonksiyonu uart üzerinden belli bir byte alındıktan sonra bir kere çalışır. Uart tan gelen her bir byte ta USART1_IRQHandler() fonksiyonuna dallanır program. Uart hal kütüphaneleri ile okumak burada çok kullanışlı değil. Çünkü hal_uart_receive_it() fonksiyonu veya diğeri sizden UART tan kaç byte veri okunacağına dair sizden bir parametre bekler fakat server ın göndereceği byte lar belli bir uzunlukta değildir mesajın boyutuna göre değişiklik gösterir. Daha sağlıklı okuma için kendi uart interrupt kodlarınızı geliştirmenizi öneririm. Hatta DMA ile okursanız daha iyi olacaktır. Yazıdaki örnekte receive_it fonksiyonu ile 100 byte okunacak şeklinde kullanmışım ama o 100 byte’ın tamamını okumadan abort_receive_it() fonksiyonunu kullanmışım. Yani buffer içerinde mesaj verisini çektikten sonra bir nevi haberleşmeyi tekrardan başlatmışım. Buradaki bekleme süresi de o yüzden. Eğer az da olsa bir bekleme olmaz ise islemci çok hızlı çalışacağı için daha paketin hepsini almadan sürekli buffer ı temizleyecektir.
Dediğim gibi bunun için daha iyi bir uart okuma algoritması geliştirilebilir.
I used the Uart_Ring buffer of another tutorial along with your tutorial to replace UArt_RxClpt. But when I use it to send it can’t send like HAL_Uart_Transmit function. If possible, can you take a look at it and help me not: “(When it connect, handling the interrupt gives me a headache 🙁
I really need your help, I’ll send you a post about Ring_buffer.
Can you send me your project codes? i’ll take a look and i’ll reply you as soon as possible.
Email: mehmettopuz127@gmail.com
Elinize sağlık. Detaylı ve açıklayıcı bir çalışma olmuş.
Teşekkürler sağolun.
Mehmet Bey merhaba
sim800c modulündeki rx1 tx1 ve rx2 tx2 ile aynı anda iki farklı mikrodenetleyici ile internet bağlantısı sağlayabilir miyiz ben denediğim zaman sadece ilk bağlanan cihaz internete girebiliyor bunun bir çözümü var mı acaba ?
Merhaba, Ben çift UART özelliğini hiç kullanmadım ama şöyle bir application nota denk geldim. Burada çift UART kullanabilmek için AT+CMNRP=1 komutunun gönderilmesi gerektiği yazıyor. Bir deneyin isterseniz.
application note link -> https://cdn-shop.adafruit.com/product-files/2637/SIM800+Series_Serial+Port_Application+Note_V1.01.pdf
Mehmet Bey ben bu yöntemi denemiştim ama olmadı, galiba sim800 sim800h sim800l ve sim800m64 için geçerli sim800c de bu özellik yok anladığım kadarıyla peki başka bir öneriniz olur mu hatta multi ip fonksiyonunu bile aktive ettim ama yinede olmadı.
Başka bir önerim yok malesef.
Hocam öncelikle yazı için çok teşekkürler .2 sorum olacaktı.Ben şimdi usb-ttl ile sim800l yi termite programı ile kullanıyorum.Paketleri yolladım sim800l yi subscriber yaptım evet cevap da alabiliyor yalnız cevap geldikten sonra bazen 2 .publishten sonra bazen 3.publishten birkaç sn sonra CLOSED bilgisi geliyor ve TCP bağlantısı kopuyor.Brokerı buradan kurdum:https://randomnerdtutorials.com/cloud-mqtt-mosquitto-broker-access-anywhere-digital-ocean/
Connect paket:0x10 0x12 0x00 0x04 0x4D 0x51 0x54 0x54 0x04 0x02 0x00 0x3C 0x00 0x06 0x41 0x42 0x43 0x44 0x45 0x46
SUBS PACKET:0x82 0x0A 0x00 0x01 0x00 0x05 0x69 0x6C 0x6B 0x65 0x72 0x00
bu paketleri yolluyorum termitten.Neden CLOSED bilgisi geliyor anlayamadım.
2.sorum gelen bilgidepublish yazıldığı zaman verinin en başında 0 geliyor daha sonra hex olarak toplma byte daha sonra yine hex olarak topic length daha sonra da topic ve mesaji geliyor bu ilk baştakiler neden geliyor?Ben bir yeri mi kaçırıyorum?
Merhaba İlker,
Bu closed bilgisi kullandığın broker’dan kaynaklı olabilir. Geçen gün yaşadığım bir olaydan bahsedeyim. STM32 ve ESP8266 ile HiveMQ’nin public broker’ına bağlanmaya çalıştım. Bağlantı gayet başarılı gerçekleşti fakat 1 sn aralıklarla sürekli olarak mesaj göndermek istediğimde 4 veya 5. gönderimden sonra bağlantı otomatik olarak kesildi. Aynı kodu local bir brokerda denediğimde 1 saat boyunca hiç kesilmeden saniyede bir publish yapabildim. 1 saat sonra bağlantıyı kendim kestim 🙂 Yani bu sorun brokerdan kaynaklı olabilir. Muhtemelen bu public brokerların bir koruma mekanizması falan var o yüzden bağlantıyı kesiyor olabilirler. Local bir broker kurup deneyebilirsin. Ayrıca GSM/GPRS modülleri internete bağlanacadkları sırada biraz fazla güç harcıyorlar diye hatırlıyorum. Eğer sim800L beslemesi yeterli değilse arada bir böyle bağlantı kopmaları yaşanabilir.
2. soruya gelecek olursak Server publish mesajı olduğu gibi client’a iletmesi gerekiyor diye biliyorum. Yani publish paketin aynısı sim800l üzerinden MCU’ya gelmesi gerekir. Bu durumda gelecek olan ilk byte publish paketin fixed header’ı olması gerekir( Qos, Dup flag ve retain bitine bağlı olarak değişebilir). Burada neden sıfır geldiğine dair bir fikrim yok fakat sıfırdan sonra gelen remain length, topic length byte’larının gelmesi normal.
Bu aralar bu MQTT için bir driver yazıyorum daha efektif bir şekilde kullanmak için. Bu yazıda MQTT kullanımı çok amatörce bunu kabul ediyorum zaten burada amacım basitçe bu iş nasıl oluyor onu anlatabilmekti. Yeni hazırladığım yazıda bu işi biraz daha profesyonelleştirip efektif bir kütüphane yazmaya çalışıyorum. En kısa zamanda o yazıyı da paylaşacağım.
Hocam cevap için teşekkürler .Dokümanda subscribe olan topic için gelen mesaj response nerede yazıyor?Belki orada başında neden 0 geldiğini açıklayan bir yer olabilir ama ben göremedim .Gönderdiğim paketlerlerde yanlışlık yok herhalde?
Gelen cevap şu şekilde :
0[14][00][05]ilkerHello, world!
[14]:Bu length olması gerek 20 bayt
[00][05]:Topic length oluyor galiba ama şu 0 ı çözemedim.
Merhaba İlker,
Bugün bir örnek proje üzerinde denedim. O örnekte de başında sıfır geldi. Fakat bu sıfır karakter olarak sıfır yani hex karşılığı ascii tablosundan 0x30 oluyor:). İlk başlarda ben de diyorum bu sıfır nasıl geldi falan. Kendim test edince farkettim ki bu karakter olan “0” ve bunun decimal karşılığı 48, hex karşılığı ise 0x30.
Bu arada bu yazıda belirtmemişim ama benim faydalandığım dökümanın linkini aşağıya bırakıyorum İlker. Kolay gelsin.
http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.pdf
Hocam bende buradan bakıyordum bu dokümanda nerede yazıyor 0 geldiği ben o kısmı bulamadım.
Şu mu oluyor yani publish paketi 0x30 olduğu için mi 0 x30 ile başlıyor?
Dökümanda 16. Sayfada 2.2.1 MQTT Control Packet type başlığı altında bahsedilmiş. O sayfada demiş ki Publish için bu değer 3 fakat bu 4 bitlik bir değer ve control byte’ın MSB bitlerini oluşuturuyor. Yani 0x30 daki 3 buradan geliyor. Senin seri port görüntüleme aracında gördüğün ilk başta gelen karakter olarak 0 ve ascii tablosundan karşılaştırırsan bunun 0 karakterinin hexadeximal karşılığı 0x30 dur. Başka bir deyişle eğer sen seriport ekranını hex gösterecek bir şekilde ayarlarsan orada sıfır görmeyeceksin 0x30 göreceksin.