TubeMQ - Quick Start - 《Apache InLong v0.10 Documentation》

1 Deploy and Start
2 Quick Start
- 3.1 Add Topic
- 2.2 Run Example
  - 2.2.1 Produce Messages
  - 2.2.2 Consume Messages
3 The End

1 Deploy and Start

1.1 Configuration Example

There’re two components in the cluster: Master and Broker. Master and Broker can be deployed on the same server or different servers. In this example, we setup our cluster like this, and all services run on the same node. Zookeeper should be setup in your environment also.

Role	TCP Port	TLS Port	Web Port	Comment
Master	8099	8199	8080	Meta data is stored at /stage/meta_data
Broker	8123	8124	8081	Message is stored at /stage/msg_data
Zookeeper	2181			Offset is stored at /tubemq

1.2 Prerequisites

ZooKeeper Cluster

After you extract the package file, here’s the folder structure.

/INSTALL_PATH/inlong-tubemq-server/
├── bin
├── conf
├── lib
├── logs
└── resources

1.3 Configure Master

You can change configurations in conf/master.ini according to cluster information.

Master IP and Port

[master]
hostName=YOUR_SERVER_IP                  // replaced with your server IP
port=8099
webPort=8080
metaDataPath=/stage/meta_data

Access Authorization Token

confModAuthToken=abc                    // for configuring Web Resources\API etc

ZooKeeper Cluster

[zookeeper]                             // Master and Broker in the same cluster must use the same zookeeper environment and have the same configuration
zkNodeRoot=/tubemq
zkServerAddr=localhost:2181             // multi zookeeper addresses can separate with ","

Replication Strategy

[replication]
repGroupName=tubemqGroup1                // The Master of the same cluster must use the same group name, and the group names of different clusters must be different
repNodeName=tubemqGroupNode1             // The master node names of the same cluster must be different names
repHelperHost=FIRST_MASTER_NODE_IP:9001  // helperHost is used for building HA master.

(Optional) Master High Availability In the example above, we run the services on a single node. However, in real production environment, you need to run multiple master services on different servers for high availability purpose. Here’s the introduction of availability level.

HA Level	Master Number	Description
High	3 masters	After any master crashed, the cluster meta data is still in read/write state and can accept new producers/consumers.
Medium	2 masters	After one master crashed, the cluster meta data is in read only state. There’s no affect on existing producers and consumers.
Minimum	1 master	After the master crashed, there’s no affect on existing producer and consumer.

Tips：Please notice that the master servers should be clock synchronized.

1.4 Configure Broker

You can change configurations in conf/broker.ini according to cluster information.

Broker IP and Port

[broker]
brokerId=0
hostName=YOUR_SERVER_IP                 // replaced with your server IP
port=8123
webPort=8081

Master Address

masterAddressList=MASTER_NODE_IP1:8099,MASTER_NODE_IP2:8099   // multi addresses can separate with ","

Metadata Path

primaryPath=/stage/msg_data

ZooKeeper Cluster

[zookeeper]                             // Master and Broker in the same cluster must use the same zookeeper environment and have the same configuration
zkNodeRoot=/tubemq
zkServerAddr=localhost:2181             // multi zookeeper addresses can separate with ","

1.5 Start Master

Please go to the bin folder and run this command to start the master service.

./tubemq.sh master start

You should be able to access http://your-master-ip:8080 to see the web GUI now.

1.5.1 Configure Broker Metadata

Before we start a broker service, we need to configure it on master web GUI first. Go to the Broker List page, click Add Single Broker, and input the new broker information.

In this example, we only need to input broker IP and authToken:

broker IP: broker server ip
authToken: A token pre-configured in the conf/master.ini file. Please check the confModAuthToken field in your master.ini file.

Click the online link to activate the new added broker.

1.6 Start Broker

Please go to the bin folder and run this command to start the broker service

./tubemq.sh broker start

Refresh the GUI broker list page, you can see that the broker now is registered.

After the sub-state of the broker changed to idle, we can add topics to that broker.

2 Quick Start

3.1 Add Topic

We can add or manage the cluster topics on the web GUI. To add a new topic, go to the topic list page and click the add new topic button

Then select the brokers which you want to deploy the topics to.

We can see the publish and subscribe state of the new added topic is still grey. We need to go to the broker list page to reload the broker configuration.

When the broker sub-state changed to idle, go to the topic list page. We can see that the topic publish/subscribe state is active now.

Now we can use the topic to send messages.

2.2 Run Example

Now we can use demo topic which created before to test our cluster.

2.2.1 Produce Messages

Please don’t forget replace YOUR_MASTER_IP:port with your server ip and port, and start producer.

cd /INSTALL_PATH/apache-inlong-tubemq-server-[TUBEMQ-VERSION]-bin
./bin/tubemq-producer-test.sh --master-servers YOUR_MASTER_IP1:port,YOUR_MASTER_IP2:port --topicName demo

From the log, we can see the message is sent out.

2.2.2 Consume Messages

Please don’t forget replace YOUR_MASTER_IP:port with your server ip and port, and start consumer.

cd /INSTALL_PATH/apache-inlong-tubemq-server-[TUBEMQ-VERSION]-bin
./bin/tubemq-consumer-test.sh --master-servers YOUR_MASTER_IP1:port,YOUR_MASTER_IP2:port --topicName demo --groupName test_consume

From the log, we can see the message received by the consumer.

3 The End

Here, the compilation, deployment, system configuration, startup, production and consumption of TubeMQ have been completed. If you need to understand more in-depth content, please check the relevant content in “TubeMQ HTTP API” and make the corresponding configuration settings.