iTools® MQTT driver

07.03.17

Nel primo esempio viene mostrato come creare un driver IToolS MQTT Publisher per scrivere su un broker MQTT dei topic legati alle variabili IToolS


using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;


namespace TestMQTTPublisherDriver
{
   class Program
   {
      static void Main(string[] args)
      {
         bool exit = false;

         IToolS.Components.ComponentBase.RaiseEventsOnMainThread = false;

         IToolS.Components.Communication.Client client = null;
         IToolS.Components.Communication.Variable var1 = null;

         var1 = new IToolS.Components.Communication.Variable() { VariableName = "Temperature1" };
         var1.PublishName = "/itools/temperature1";

         var1.Changed += (sender, e) =&gt;
         {
            Console.WriteLine("Topic: {0}; Value: {1}", var1.Address, e.NewValue);
         };

         client = new IToolS.Components.Communication.Client();
         IToolS.Components.Communication.Group group = new IToolS.Components.Communication.Group();

         group.Items.Add(var1);

         client.Group = group;
         client.IOServer = new IToolS.Components.IOServers.IOServer() { Name = "MQTTPublisher" };
         client.IOServer.NetConfig.Address = "broker.hivemq.com";
         client.IOServer.NetConfig.Port = 1883;


         client.Start();

         Thread t = new Thread(() =&gt;
         {
            Random r = new Random();

            while (!exit)
            {
               var1.Value = r.Next(1000, 5000);

               Thread.Sleep(2000);
            }

         });
         t.Start();

         Console.WriteLine("Press ENTER to exit");
         Console.ReadLine();

         exit = true;

         t.Join(5000);

         client.Stop();
         client.StopIOServer();
      }
   }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading;

namespace TestMQTTPublisherDriver

{

class Program

{

static void Main(string[] args)

{

bool exit = false;

IToolS.Components.ComponentBase.RaiseEventsOnMainThread = false;

IToolS.Components.Communication.Client client = null;

IToolS.Components.Communication.Variable var1 = null;

var1 = new IToolS.Components.Communication.Variable() { VariableName = "Temperature1" };

var1.PublishName = "/itools/temperature1";

var1.Changed += (sender, e) =>

{

Console.WriteLine("Topic: {0}; Value: {1}", var1.Address, e.NewValue);

};

client = new IToolS.Components.Communication.Client();

IToolS.Components.Communication.Group group = new IToolS.Components.Communication.Group();

group.Items.Add(var1);

client.Group = group;

client.IOServer = new IToolS.Components.IOServers.IOServer() { Name = "MQTTPublisher" };

client.IOServer.NetConfig.Address = "broker.hivemq.com";

client.IOServer.NetConfig.Port = 1883;

client.Start();

Thread t = new Thread(() =>

{

Random r = new Random();

while (!exit)

{

var1.Value = r.Next(1000, 5000);

Thread.Sleep(2000);

}

});

t.Start();

Console.WriteLine("Press ENTER to exit");

Console.ReadLine();

exit = true;

t.Join(5000);

client.Stop();

client.StopIOServer();

}

Nel secondo esempio viene mostrato come creare un driver IToolS MQTT Subscriber per leggere dei topic da un broker MQTT legati alle variabili IToolS


using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace TestMQTTSubscriberDriver
{
   class Program
   {
      static void Main(string[] args)
      {
         IToolS.Components.ComponentBase.RaiseEventsOnMainThread = false;

         IToolS.Components.Communication.Client client = null;
         IToolS.Components.Communication.Variable var1 = null;

         var1 = new IToolS.Components.Communication.Variable();
         var1.Address = "/itools/temperature";

         var1.Changed += (sender, e) =&gt; 
         {
            Console.WriteLine("Topic: {0}; Value: {1}", var1.Address, e.NewValue);
         };

         client = new IToolS.Components.Communication.Client();
         IToolS.Components.Communication.Group group = new IToolS.Components.Communication.Group();

         group.Items.Add(var1);

         client.Group = group;
         client.IOServer = new IToolS.Components.IOServers.IOServer() { Name = "MQTTSubscriber" };
         client.IOServer.NetConfig.Address = "broker.mqttdashboard.com";
         client.IOServer.NetConfig.Port = 1883;

         client.Start();

         Console.WriteLine("Press ENTER to exit");
         Console.ReadLine();

      }
   }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

namespace TestMQTTSubscriberDriver

{

class Program

{

static void Main(string[] args)

{

IToolS.Components.ComponentBase.RaiseEventsOnMainThread = false;

IToolS.Components.Communication.Client client = null;

IToolS.Components.Communication.Variable var1 = null;

var1 = new IToolS.Components.Communication.Variable();

var1.Address = "/itools/temperature";

var1.Changed += (sender, e) =>

{

Console.WriteLine("Topic: {0}; Value: {1}", var1.Address, e.NewValue);

};

client = new IToolS.Components.Communication.Client();

IToolS.Components.Communication.Group group = new IToolS.Components.Communication.Group();

group.Items.Add(var1);

client.Group = group;

client.IOServer = new IToolS.Components.IOServers.IOServer() { Name = "MQTTSubscriber" };

client.IOServer.NetConfig.Address = "broker.mqttdashboard.com";

client.IOServer.NetConfig.Port = 1883;

client.Start();

Console.WriteLine("Press ENTER to exit");

Console.ReadLine();

}

Nel terzo esempio viene mostrato come creare un driver modbus IToolS e pubblicare il valore di una variabile IToolS su un topic MQTT:



using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;

namespace TestMQTTPublisherDriverModbusClient
{
   using IToolS.Components;
   using IToolS.Components.Communication;
   using IToolS.Components.IOServers;

   class Program
   {
      static void Main(string[] args)
      {
         ComponentBase.RaiseEventsOnMainThread = false;

         Client client = null;
         Variable var1 = null;

         IOServer ioServer = new IOServer();
         ioServer = new IOServer() { Name = "MQTTPublisher" };
         ioServer.NetConfig.Address = "broker.mqttdashboard.com";
         ioServer.NetConfig.Port = 1883;

         var1 = new Variable() { VariableName = "var1", Address = "100", Area = "HR" };
         var1.PublishName = "/itools/temperature";

         var1.Changed += (sender, e) =&gt;
         {
            Console.WriteLine("Topic: {0}; Value: {1}", var1.PublishName, e.NewValue);
         };

         client = new Client();

         Group group = new Group();
         group.Items.Add(var1);

         group.IOServer = ioServer;

         client.Group = group;
         client.IOServer = new IOServer() { Name = "ModnetMaster" };

         client.Start();

         group.StartIOServer();

         Console.WriteLine("Press ENTER to exit");
         Console.ReadLine();

         client.Stop();
         client.StopIOServer();

         group.StopIOServer();
      }
   }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading;

namespace TestMQTTPublisherDriverModbusClient

{

using IToolS.Components;

using IToolS.Components.Communication;

using IToolS.Components.IOServers;

class Program

{

static void Main(string[] args)

{

ComponentBase.RaiseEventsOnMainThread = false;

Client client = null;

Variable var1 = null;

IOServer ioServer = new IOServer();

ioServer = new IOServer() { Name = "MQTTPublisher" };

ioServer.NetConfig.Address = "broker.mqttdashboard.com";

ioServer.NetConfig.Port = 1883;

var1 = new Variable() { VariableName = "var1", Address = "100", Area = "HR" };

var1.PublishName = "/itools/temperature";

var1.Changed += (sender, e) =>

{

Console.WriteLine("Topic: {0}; Value: {1}", var1.PublishName, e.NewValue);

};

client = new Client();

Group group = new Group();

group.Items.Add(var1);

group.IOServer = ioServer;

client.Group = group;

client.IOServer = new IOServer() { Name = "ModnetMaster" };

client.Start();

group.StartIOServer();

Console.WriteLine("Press ENTER to exit");

Console.ReadLine();

client.Stop();

client.StopIOServer();

group.StopIOServer();

}

Blog

iTools® MQTT driver

Lascia un commento Annulla risposta