stevenlee123 / mq-console-demo1

rocketmq消息中间件学习1

#RocketMQ-Console-Ng #How To Use

With Docker

• get docker image

mvn package docker:build

or

docker pull styletang/rocketmq-console

• run it (change namesvrAddr and port yourself)

docker run -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 8080:8080 -t styletang/rocketmq-console

Without Docker

• require java 1.7

• 0.if you download package slow,you can change maven's mirror(maven's settings.xml)

  <mirrors>
      <mirror>
            <id>alimaven</id>
            <name>aliyun maven</name>
            <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
            <mirrorOf>central</mirrorOf>        
      </mirror>
  </mirrors>
  

• 1.if you use the rocketmq < 3.5.8,please add -Dcom.rocketmq.sendMessageWithVIPChannel=false when you start rocketmq-console

• 2.change the rocketmq.namesrv.addr in resource/application.properties.

• 3.mvn spring-boot:run

#Deploy Plan

we will deploy the first rocketmq-console-ng use rocketmq-tools 3.5.8(or 4.0.0),base on rocket-console，thanks didapinche.com

Framework

• 0. we use spring-boot + bootstrap + angularjs

something to improve

• 0. clean code (checkStyle codeStyle to be done)
• 1. international
• 2. compress fe'resource
• 3. navigation bar can improve
• 4. write operation need confirm,action show the detail result
• 5. layout/UI should improve
• 6. change to spring-boot

something to fix

• query Message by topic and time is not accurate， will lost some message
• consumer can consume the message when topic has been deleted
• can't show producerList,we can only query a online producer use topic and groupName,not easy to use.
• resetOffset should be improve,online consumer can return the reset result but offline's can't
• we can't set clusterName when create topic or consumer
• when create a new consumer,if not be consumed,can't be found in consumerList

something to add

• 1. dashboard

Roadmap

Improve

• clean code (checkStyle codeStyle to be done) -- StyleTang
• international -- Deploy by tcrow
• layout/UI -- Deploy by tcrow
  • compress fe'resource
  • navigation bar can improve
  • write operation need confirm,action show the detail result || already have
  • layout/UI should improve
• change to spring-boot -- Deploy by syzjava
• change to bootstrap angularjs -- Deploy by tcrow
• improve search message --StyleTang

Fix

• query Message by topic and time is not accurate， will lost some message -- StyleTang (need test)
• consumer can consume the message when topic has been deleted // offset be clear.if have problem,reopen it.
• can't show producerList,we can only query a online producer use topic and groupName,not easy to use. need this issues
• resetOffset should be improve,online consumer can return the reset result but offline's can't //this version(3.5.8) may be can't fix
• we can't set clusterName when create topic or consumer -- StyleTang
• when create a new consumer,if not be consumed,can't be found in consumerList //it Fixed,But this page is too slow,need improve --StyleTang
• message view page,resend message (version >=3.5.8) have bug -- StyleTang

Add

• DashboardController -- Deploy by tcrow
  • rocketmq topic tps 5m line chart
  • rocketmq topic top10 table
  • broker load 5m line chart
  • broker load top10 table
  • topic exception table

Already Have (Deploy by StyleTang) But Can Improve

Cluster

• ClusterController
  • Cluster OverView
  • Broker Status
  • Broker Config

Topic

• TopicController
  • TopicList
  • Topic Status
  • Topic Router
  • View Topic Config
  • Topci Add / Update
  • Send A Test Topic
  • Reset ConsumerGroup's Offset Under This Topic
  • Delete This Topic

Producer

• ProducerController
  • Producer Client Info

Consumer

• ConsumerController
  • ConsumerList
  • Consumer Client Info
  • Topic Consume Status Under This Consumer Group
  • View Consumer Config
  • Consumer Add / Update
  • Delete This Consumer

Message

• MessageController
  • Query By Topic And Time
  • Query By Topic And Key
  • Query By MessageId(OffsetMessageId)
  • A Nice Message Detail View
  • Message Consume Status
  • Resend Message To A Consume Group

#Communicate With Us

• QQ Group:535273860
• You can communicate with us use QQ.(or send us issue / pull request)
• You can join us and make a contribute for rocketmq-console-ng.