6

GSM/GPRS Modülü İle MQTT Protokolünün Kullanımı

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.

Port Yönlendirme

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.

MQTT Paket Formatı

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.

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.

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.

Publish Paket Formatı

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.

  1. 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.
  2. Daha sonra 0x30 değerinden sonraki 3 değer okunup topic adı uzunluğu ve remain length çekilir.
  3. message_length = remain_length -(topic_length + 2) ile okunacak olan mesaj uzunluğu hesaplanır.
  4. 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.

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.

Aşağıda MyMQTT ile gönderdiğim komutlara karşılık gelen cevapların ekran görüntülerini ekledim.

MyMQTT Uygulaması

MyMQTT Uygulaması

STM32 Kodlarının Tamamı

Proje dosyasını Github‘tan indirmek için buraya tıklayabilirsiniz.

Yazıda yanlış bir bilgi veya gözden kaçırdığım eksik bir şey varsa yorumlarda belirtiniz.

İyi Çalışmalar…

Mehmet Topuz

Mehmet Topuz

6 Comments

  1. 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.

  2. 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.

Bir cevap yazın

E-posta hesabınız yayımlanmayacak. Gerekli alanlar * ile işaretlenmişlerdir