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.
- 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
- 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 stopin the same folder as above - Logs can be observed via
docker-compose logs [CONTAINER](ex: ioe-app)
- Clone the Github repository
- Install and configure Cassandra (http://cassandra.apache.org/doc/latest/getting_started/installing.html)
- Configure 'ioe' section in application.yml that can be found in rest_api/src/main/resources/config. Set cassandraUrl to localhost.
- 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 runin order to start the broker.
- Spring Boot is run by 'gradlew' executable in /rest_api. Run
sudo ./gradlewto 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.
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.
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"}
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
- Need to implement authentication for Publish Subscribe
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent