RabbitMQ-IoTDB Demo

Function

The example is to show how to send data from localhost to IoTDB through RabbitMQ.

Usage

Version usage

IoTDB: 0.12.0
RabbitMQ server: 3.8.15 RabbitMQ client jar: 5.12.0

Dependencies with Maven

<dependencies>
    <dependency>
        <groupId>org.apache.iotdb</groupId>
        <artifactId>iotdb-jdbc</artifactId>
        <version>${project.version}</version>
    </dependency>
    <dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>5.12.0</version>
    </dependency>
</dependencies>

1. Install IoTDB

please refer to https://iotdb.apache.org/#/Download

2. Install RabbitMQ

please refer to https://www.rabbitmq.com/download.html

3. Startup IoTDB

please refer to Quick Start

4. Startup RocketMQ

please refer to https://www.rabbitmq.com/download.html

5. Start the consumer client: RabbitMQConsumer

6. Start the producer client: RabbitMQProducer