IoTTP.Core

Internet of things transport protocol (IoTTP) library for edge computing based on MQTT protocol.

Feature(implemented)

Executes a remote command and returns the result dynamically
Client decides whether to return an execution result as needed
Remote command execution log (process start and stop state)
Support multi-session, multi-process concurrent execution, return result session isolation
Support client specified command execution duration (expiration is automatically cancelled to avoid resource waste)
Whether the same command is Multiton executed
Support for communicating with child processes via named pipes (passing execution parameters)

Support platform

Windows
Linux
MacOS

How to use?

Device (broker, executive command)

var serverUri = new Uri("iottp://broker.hivemq.com");
var userName = "guest";
var password = "guest";

//Device unique, if empty system automatically generated
var deviceId = new Guid("97c8bc6e-0709-4b2e-82ef-298f42d91dcc");
var broker = new IoTTP.Core.Broker(deviceId);
await broker.StartAsync(serverUri, userName, password);

Client (send command)

var serverUri = new Uri("iottp://broker.hivemq.com");
var userName = "guest";
var password = "guest";

//find all the devices you can control(For now only RabbitMQ)
//var queueApi = $"http://{serverUri.Host}:{15672}/api/queues";
//var devices = await Discover.FindAsync(new Uri(queueApi), userName, password);

//consistent with device side, Or from the devices found.
var deviceId = new Guid("97c8bc6e-0709-4b2e-82ef-298f42d91dcc");
var client = new Client(deviceId);
await client.ConnectAsync(serverUri, userName, password);

var commandLine = Console.ReadLine(); //for example: "ping bing.com"
var command = new CommandBuilder().FromLine(commandLine).Build();
var requestMessage = new RequestMessage(command, command.Method);
await client.RequestAsync(requestMessage, (ResponseMessage<string> responseMessage) =>
    {
        //The return contents of the program can be defined on the device side, such as the json string after the object has been serialized, where it can be deserialized.
        var content = responseMessage.Content;
        Console.WriteLine(content);
    });

TODO

Device side security verification
Support for SSL/TSL
Offline storage, online retransmission
Test performance in different operating system environments
And much more...

Build Status

In progress

Proposal

We welcome people of insight to develop this project together, Thanks.