Skip to content

Open-source middleware platform for building, managing, and integrating connected products with the Internet of Everything.

License

Notifications You must be signed in to change notification settings

IOTs-Projects/OpenIoE

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Gitter Build Status GitHub license Codacy Badge

OpenIoE

OpenIoE is an Open-source middleware platform for building, managing, and integrating connected products with the Internet of Everything. It enables you to subscribe to data streams and get data from the sensors and store them. The application was generated using JHipster application generator.

Main features

  • A high-perfomance Java server side with Spring Boot
  • Message broker support with ActiveMQ Artemis
  • Multi Protocol support (MQTT, AMQP)
  • NoSQL data storage for sensor data (Cassandra)
  • Support for timeline series modelling
  • Publish-subscribe feature using MQTT

Docker

  • All the services required to run the platform can be easily started via bundled docker-compose.yml located in rest_api/src/main/docker
  • Browse to rest_api/src/main/docker and run docker-compose up -d
  • Open 127.0.0.1 in the web browser where you can configure a user account and create devices and sensors
  • To stop the platform, run docker-compose stop in the same folder as above
  • Logs can be observed via docker-compose logs [CONTAINER] (ex: ioe-app)

Installation

Usage

  • Make sure Cassandra server is up. You can start Cassandra with 'sudo service cassandra start' and stop it with 'sudo service cassandra stop'. Verify that Cassandra is running by invoking nodetool status from the command line.
  • To run the artemis message broker (Compiled using ActiveMQ Artemis 1.5.x),
    • In '/message_broker/etc/artemis.profile' file, change the ArtemisHome directory to match your Apache ActiveMQ Artemis installation directory and java.security.auth.login.config of JAVA_ARGS to match OpenIOE 'message_broker/etc/login.config'.
    • In '/message_broker/etc/bootstrap.xml' file, change the server configuration path to match OpenIOE 'message_broker/etc/broker.xml' file.
    • The executable for running the artemis message broker is found in '/message_broker/bin'. Run ./artemis run in order to start the broker.
  • Spring Boot is run by 'gradlew' executable in /rest_api. Run sudo ./gradlew to start running the application.
  • Open 127.0.0.1 in the web browser where you can configure a user account and create devices, sensors, subscriptions and publications.

Publish - subscribe behavior

The sensor data can be published using rest end point and message broker with MQTT support. Both methods accept the payload as JSON. An example for publishing data with rest endpoint using curl command is

curl -X POST --header 'Content-Type: application/json' --header 'Accept: application/json' --header 'Authorization: Bearer <access_token>' -d '{
  "data": "24",
  "description": "test",
  "sensorId": 1,
  "timestamp": "2017-03-19T09:47:44.526Z",
  "topic" : "gps"
}' 'http://127.0.0.1:8080/api/sensors/{id}'

The user can also publish data using MQTT protocol with MQTT client applications by sending the data of the following form to the topic 'gps'.

  "data": "24",
  "description": "test",
  "sensorId": 1,
  "timestamp": "2017-03-19T09:47:44.526Z"

The user can subscribe to topics defined for subscription entity using MQTT client applications by providing the topic name as gps. Whenever a new data is published, it will be stored in Cassandra and can be received by the user.

Storing data

Data can be stored via the REST endpoint and the message broker. Both methods accept the payload as JSON. An example is {"sensorId":1,"data":"24","description":"test","timestamp":"2016-07-30T21:29:34+02:00"}

Retreiving data

Using the REST end point data can be retreived. http://127.0.0.1:8080/api/sensors/1/data where 1 is the sensor id http://127.0.0.1:8080/api/sensors/1/data?dates=2016-07-30,2016-07-2 where multiple dates can be specified

  • The requests should pass the Authentication token

Future work

  • Need to implement authentication for Publish Subscribe

About

Open-source middleware platform for building, managing, and integrating connected products with the Internet of Everything.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Java 38.1%
  • JavaScript 25.3%
  • CSS 15.5%
  • HTML 15.3%
  • C 3.5%
  • Scala 1.6%
  • Other 0.7%