# RocketMQ-Console

**Repository Path**: M-Analysis/rocket-mq-console

## Basic Information

- **Project Name**: RocketMQ-Console
- **Description**: RocketMQ-Console
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 3
- **Created**: 2021-10-14
- **Last Updated**: 2023-02-03

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## RocketMQ-Console

## How To Install

修改application.properties

```
vim src/main/resources/application.properties

#这个填写自己的nameserver的地址，默认是localhost:9876
rocketmq.config.namesrvAddr=localhost:9876
#rocketmq-console的数据目录，默认为 /tmp/rocketmq-console/data
rocketmq.config.dataPath=/usr/local/rocketmq-console/data
#开启认证登录功能，默认为false
rocketmq.config.loginRequired=true
```

使用Maven编译

```go
mvn clean package -Dmaven.test.skip=true
```

运行

![image-20211014231025113](img/image-20211014231025113.png)

或者在服务器上

```
#新建一个目录用来存放rocketmq-console的文件
mkdir  /usr/local/rocketmq-console
cp target/rocketmq-console-ng-1.0.1.jar /usr/local/rocketmq-console/
#运行这个jar包
cd  /usr/local/rocketmq-console/
nohup java -jar rocketmq-console-ng-1.0.1.jar &
```

打开浏览器验证

![image-20211014231238568](img/image-20211014231238568.png)

![image-20211014231317921](img/image-20211014231317921.png)



测试一个小Demo

![image-20211014231930956](img/image-20211014231930956.png)

```java
/**
 * @description： Provider测试
 * @Author MRyan
 * @Date 2021/10/13 22:00
 * @Version 1.0
 */
public class App {

    public static DefaultMQProducer defaultMQProducer = new DefaultMQProducer("default_group");

    public static void main(String[] args) throws MQClientException, UnsupportedEncodingException,
            MQBrokerException, RemotingException, InterruptedException {
        defaultMQProducer.setNamesrvAddr("localhost:9876");
        defaultMQProducer.start();
        Message msg = new Message("broker-a", "TagA", "itemId is traded".getBytes(RemotingHelper.DEFAULT_CHARSET));
        SendResult send = defaultMQProducer.send(msg);
        System.out.println(send);
    }
}

```

运行程序

![image-20211014232008185](img/image-20211014232008185.png)

![image-20211014232050276](img/image-20211014232050276.png)

```java
/**
 * @description： Consumer测试类
 * @Author MRyan
 * @Date 2021/10/13 22:14
 * @Version 1.0
 */
public class App {

    public static void main(String[] args) throws MQClientException {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("default_group");
        consumer.setNamesrvAddr("localhost:9876");
        consumer.subscribe("broker-a", "");
        consumer.registerMessageListener((MessageListenerConcurrently) (list, consumeConcurrentlyContext) -> {
            System.out.println("Receive message+" + list);
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        });
        consumer.start();
    }

}
```



![image-20211014232106236](img/image-20211014232106236.png)