Intel Edison üzerinde Azure Service Bus Queue

Merhaba arkadaşlar,

Bir önceki yazımda Azure Service Bus’ı örnek senaryolarla birlikte elimden geldiğince açıklamaya çalışmıştım. Bu yazımda Intel Edison üzerinden Azure Service Bus Namespace’imizde bulunan bir Queue’ya nasıl veri aktarırız onu anlatmaya çalışacağım.

Bu yazının amacı gereği mesajı bir Intel Edison cihazdan göndereceğiz, bir Console Application‘dan mesajları consume edeceğiz. Yazının bu kısmından sonrasını biraz daha az detaylı anlatacağım, en sonda kaynak kodları paylaşacağım.

Intel Edison üzerinde mesaj gönderecek olan uygulamamızı yazmak için Nodejs kullanacağız. Çünkü Arduino’nun WifiClient, WebClient kütüphanelerinde SSL bağlantıları kuramıyoruz.

Message Sender’ı hazırlayalım

Eğer daha önce hiç Nodejs kullanmadıysanız, sadece beginner seviyesinde olduğumdan sizleri yanlış yönlendirmek istemiyorum. Nodejs hakkında güzel bir giriş yazısı buldum: http://blog.ilkerguller.com/2012/01/nodejs-dersleri-bolum-1-kurulum-ve-ilk.html

Öncelikle Node commant prompt’u açalım ve aşağıdakileri sırasıyla yazalım;

> cd c:\
> mkdir serviceBusMessageSender
> cd serviceBusMessageSender

> npm init

Buradan sonra name, description, version, entry point gibi bilgiler sorulacak. Bunları girdikten sonra;
> touch [entrypoint] yazmanız gerekecek. Örneğin touch index.js.

Böylelikle uygulamamızın giriş noktasını oluşturduk. Şimdi bazı paketler yüklememiz gerekecek.

Uygulamayı oluşturduğumuz dizine gittikten sonra(serviceBusMessageSender) npm’den aşağıdaki paketleri yüklememiz gerekecek.

azure

Nodejs uygulamarında azure servislerini kullanmak için ‘azure’ pakedini yüklememiz gerekiyor.

cylon
cylon-gpio
cylon-i2c
cylon-intel-iot

Cylon paketleri ise bir Nodejs uygulamasından Edison cihazını kontrol edebilmek için kullanıyoruz. 4’ünü birden yüklememiz gerekiyor, birbirine bağımlı paketler. (http://cylonjs.com/)

Bu paketleri de yükledikten sonra entry pointimizi(index.js, app.js veya her ne ise) not defterinde açalım.

index.js
——————–

var azure = require('azure');
var Cylon = require('cylon');

var connstring = 'Endpoint=sb://xxxxx.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxxxx';
var serviceBusClient = azure.createServiceBusService(connstring);


var message = {
 customProperties: {
        TestProperty: new Date()
   }
   };

Cylon.robot({
  connections: {
    edison: { adaptor: "intel-iot" }
  },

  devices: {
    button: { driver: "button", pin: 2 }
  },

  work: function(my) {
    my.button.on("push", function () {
		serviceBusClient.sendQueueMessage('edisondataqueue', message, function(error){
    if(!error){
        // message sent
    }
});

 });
  }
}).start();

Yukarıda öncelikle yüklediğimiz kütüphanelerin referanslarını aldık. Ve daha sonra Service Bus Namespace’imizin connectionString’ini tanımladık. Bu key’i Azure Portal’dan Service Bus Namespace’inize girdikten sonra manage keys bölümünden edinebilirsiniz.

Ve Azure Service Bus üzerinde herhangi bir işlem yapmamıza olanak sağlayan serviceBusClient sınıfından bir nesne türettik.

Cylon paketi sayesinde edison bağlantımızı, cihazlarımızı ve cihaz üzerinde çalışacak fonksiyonelliği tanımladık. PIN 2’deki butonumuza basıldığında yapılacak olan işi tanımladığımız fonksiyonun içinde ise, henüz tanımladığımız serviceBusClient nesnesinin sendQueueMessage metodunu çağırarak Service Bus’taki Queue’muza mesajımızı gönderdik.

Şimdi uygulamamızı edison üzerine göndereceğiz.

Öncelikle edison üzerinde uygulamamız için bir klasör oluşturalım.

> ssh root@192.168.x.x
> mkdir servicebusapp

WinSCP(http://winscp.net/eng/download.php)’yi yükledikten sonra aşağıdaki kodu prompt’a yazarak uygulamamızı Intel Edison’a göndereceğiz ve çalışabilir hale gelecek.

> scp -r serviceBusMessageSender root@192.168.x.x:/home/wwwroot/servicebusapp

Bu komuttan sonra bir süre sonra uygulamamız gönderilmiş olacak.

> cd servicebusapp
> node index.js

Ve uygulamamız çalışıyor, pin 2’deki  butona bastığınızda Service Bus’a mesajın gönderildiğini göreceksiniz.

Consumer uygulamamızı hazırlayalım

  • Consumer uygulamamız C# Console Application olacak. Visual Studio’dan File -> New Project -> Console Application ile uygulamamızı oluşturalım.
  • Solution Explorer‘da projenin üzerine sağ tıklayıp Manage Nuget Packages‘e tıklayalım.
  • service bus‘ yazıp aratalım ve ilk sırada çıkan paketi yükleyelim. Şu anki sürüm: 2.6.5

Paket yüklendikten sonra app.config dosyasında Service Bus Namespace’imiz için ConnectionString’i ayarlamamız gerekiyor.

<appSettings>
<add key="Microsoft.ServiceBus.ConnectionString"
value="Endpoint=sb://xxxxxxx.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxxxxxxx="/>
</appSettings>

 

Program.cs
——————————————–

class Program
    {
        static string _connStr = CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");
        static void Main(string[] args)
        {
            QueueClient qc = QueueClient.CreateFromConnectionString(_connStr, "edisondataqueue");

            OnMessageOptions options = new OnMessageOptions();
            options.AutoComplete = false;
            options.AutoRenewTimeout = TimeSpan.FromMinutes(1);

            qc.OnMessage((message) =>
            {
                Console.WriteLine("NEW MESSAGE");
                Console.WriteLine("MessageID: " + message.MessageId);
                Console.WriteLine(message.Properties["testproperty"]);
                Console.WriteLine();
                Console.WriteLine();

                
                message.Complete();
            });

            Console.Read();

        }
    }

Uygulamayı derleyip çalıştıralım. Edison üzerinde butona basıldığında Console Uygulamamıza mesajın geldiğini göreceğiz.

Projenin tamamı: http://1drv.ms/1OjAEn6

Bu yazıda Intel Edison üzerinden Service Bus’ta bulunan bir Queue’ya mesaj gönderdik. Faydalı olması dileğiyle.

Fazlasını Oku

Azure Service Bus Queue : Genel Bakış

Merhaba arkadaşlar,

Bu yazımda Azure Service Bus Queue ile ilgili bilgiler vermeye çalışacağım.

Brokered Messaging

Öncelikle Brokered Messaging kavramından bahsetmek isterim. Brokered Messaging altyapısında mesajlar güvenilir bir broker’da –broker’ı aracı olarak çevirebiliriz sanırım– saklanır. Broker, mesajları alacak olan consumer uygulamanın mesajları almaya hazır duruma gelinceye kadar saklar.

Bu mesajlaşma modeli sayesinde dağıtık uygulamalar birbiriyle bağlantılı olmadan çalışır, mesajlarını broker’a gönderir. Dağıtık sistemdeki cihazların birinin bakımı sırasında veya olası bir çökme durumunda bu durumdan tüm sistem etkilenmemiş olur.

Şimdi bir dağıtık uygulama örneği vermeye çalışacağım.

Uluslararası bir lojistik firması olduğumuzu düşünelim ve bize bağlı olan 1000 transport aracı var. Ve biz bu araçların konumlarını 10 saniyede bir almak istiyoruz.

Mevcut senaryoda göre 10 saniyede bir 1000 cihazdan veri alacağız. Bunları alınıp işlenmesi sunucuya çok büyük bir yük olacaktır.

Brokered Messaging modeli uygulandığında bu istekleri karşılayacak bir sunucunun bulunup bulunmaması önemli değildir, cihazların istekleri gönderdiklerinde bir yanıt almaları da şart değildir. Cihaz mesajını gönderir, ve bu mesajı birinin almadığını önemsemez. Herhangi bir yanıt da beklemez, çalışmasına devam eder.

Consumer uygulama –yani mesajları alacak olan uygulama– eğer hazır durumdaysa mesajları anlık olarak alır ve işler. Herhangi bir bakım veya bozulma durumunda ise kuyruktaki mesajlar zarar görmez, hazır olduğunda tekrar mesajları alıp işlemeye devam eder.

Azure Service Bus Queue

Service Bus’ta bulunan Queue’lar –bundan sonra kuyruk diyeceğim– biraz önce bahsettiğimiz bir brokered messaging gerçeklemesidir. Dağıtık uygulamalar tüm mesajlarını bir kuyruk yapısına gönderir. Hepimizin bildiği gibi kuyruklar FIFO – First in First out (İlk giren ilk çıkar) prensibine göre çalışır.

service-bus-queue

Yukarıdaki grafikte gördüğümüz gibi Message Sender: mesaj gönderen uygulama Azure Service Bus Namespace’imizde yer alan kuyruğa mesajları bırakır ve basitçe Message Receiver: mesajları alacak olan uygulama, consumer Queue’dan mesajları alır ve işler.

Queue’nun çalışma modeli gereği consumer uygulama mesajların gönderilme sırasına göre ilk gönderileni öncelikli olarak okur ve kuyruktan siler. (Dequeue)

Mesaj gönderen uygulama bir web sitesi, mobil uygulama veya servis olabilir. Aklınıza gelebilecek olan bütün teknolojileri kullanarak Azure Service Bus Queue’ya mesaj gönderip alabiliyoruz. Zira Azure Service Bus REST API destekliyor.

Azure Service Bus Namespace’i oluşturma

Azure Portal’ında soldaki menüden Service Bus bağlantısına tıklayın.

1

Burası Service Bus Namespace’lerimizi görebileceğimiz ve yönetebileceğimiz sayfadır. Açılan sayfadan Create New Namespace bağlantısına tıklayın.

Azure Service Bus Namespace oluşturma

Açılacak olan formda bizden

  1. Namespace ismi
  2. Bölge
  3. Tip 
  4. Tier* bilgileri isteniyor.

*Tier’ı abonelik pakedi olarak çevirebiliriz, fiyatlandırma ayrıntıları için: Azure Service Bus Fiyatlandırma

Type olarak Messaging‘i seçmemiz gerekiyor, Notification Hub’ı Push notification için kullanıyoruz. İleride bununla ilgili bir yazı yazarsam değinebilirim : ) Tier için ise Basic seçmemiz yeterli olacaktır. Formu gönderdikten yaklaşık 30 saniye sonra Service Bus Namespace’imiz kullanılabilir olacak.

Service Bus Queue Oluşturma

Service Bus Namespace’imiz oluşturulduktan sonra üzerine tıklayıp bu namespace’i yöneteceğimiz sayfaya ilerleyeceğiz.

3

Service Bus Namespace’imizi oluşturduk. Şimdi bir Queue oluşturmamız gerekiyor. Yönetim sayfasından Queues sekmesine gitmemiz gerekiyor.

4

Queues sekmesine gittiğimizde Queue’larımızı burada görüyor olacağız. Tabii ki henüz hiçbir queue oluşturmadığımız için burası boş gelecek. Yeni bir Queue oluşturmak için Create New Queue bağlantısına tıklayacağız.

5

Create New Queue bağlantısına tıkladığımızda karşımıza bir pencere açılacak ve Queue için bilgiler girmemiz istenecek.

6

  1. Queue Name
  2. Region
  3. Namespace

bilgilerini gireceğiz. Queue için bir isim seçtikten sonra Türkiyeye en yakın konum olan West Europe’u seçeceğiz. Namespace için de biraz önce oluşturduğumuz Namespace’i seçeceğiz ki zaten bunlar seçili gelecek. Ve formu gönderiyoruz. Birkaç saniye sonra Queue’muz kullanıma hazır olacak.

7

Artık mesaj göndermeye ve almaya hazırız.

Bu yazımda Azure Service Bus Queue’yu elimden geldiğince açıklamaya çalıştım. Örnek senaryolar vermeye çalıştım. Faydalı olması dileğiyle.

Şu yazımda Intel Edison üzerinden Azure Service Bus Queue’ya mesaj göndermekten ve C# Console Application’dan mesajları consume etmekten bahsettim: Intel Edison üzerinde Azure Service Bus Queue

Fazlasını Oku