message-queue-parent:消息队列(ActiveMQ、Kafka、RabbitMQ、RocketMQ等)示例-源码

[{"title":"（ 59 个子文件 54KB ） message-queue-parent:消息队列(ActiveMQ、Kafka、RabbitMQ、RocketMQ等)示例-源码","children":[{"title":"message-queue-parent-master","children":[{"title":".gitignore <span style='color:#111;'> 395B </span>","children":null,"spread":false},{"title":"kafka-parent","children":[{"title":"pom.xml <span style='color:#111;'> 798B </span>","children":null,"spread":false},{"title":"kafka-java","children":[{"title":"pom.xml <span style='color:#111;'> 629B </span>","children":null,"spread":false}],"spread":true},{"title":"kafka-spring","children":[{"title":"pom.xml <span style='color:#111;'> 631B </span>","children":null,"spread":false}],"spread":true},{"title":"kafka-springboot","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"KafkaApplication.java <span style='color:#111;'> 362B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"KafkaApplicationTests.java <span style='color:#111;'> 207B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"activemq-parent","children":[{"title":"activemq-java","children":[{"title":"pom.xml <span style='color:#111;'> 638B </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 813B </span>","children":null,"spread":false},{"title":"activemq-spring","children":[{"title":"pom.xml <span style='color:#111;'> 640B </span>","children":null,"spread":false}],"spread":true},{"title":"activemq-springboot","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"ActiveApplication.java <span style='color:#111;'> 449B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"ActiveApplicationTests.java <span style='color:#111;'> 208B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.25KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 85B </span>","children":null,"spread":false},{"title":"rocketmq-parent","children":[{"title":"rocketmq-java","children":[{"title":"pom.xml <span style='color:#111;'> 638B </span>","children":null,"spread":false}],"spread":true},{"title":"rocketmq-springboot","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"RocketApplication.java <span style='color:#111;'> 449B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"RocketApplicationTests.java <span style='color:#111;'> 208B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.24KB </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 813B </span>","children":null,"spread":false},{"title":"rocketmq-spring","children":[{"title":"pom.xml <span style='color:#111;'> 640B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"rabbitmq-parent","children":[{"title":"rabbitmq-java","children":[{"title":"pom.xml <span style='color:#111;'> 638B </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false},{"title":"rabbitmq-springboot","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 168B </span>","children":null,"spread":false},{"title":"banner1.txt <span style='color:#111;'> 1.23KB </span>","children":null,"spread":false},{"title":"banner.txt <span style='color:#111;'> 2.53KB </span>","children":null,"spread":false},{"title":"banner2.txt <span style='color:#111;'> 1.73KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"domain","children":[{"title":"MqMessage.java <span style='color:#111;'> 341B </span>","children":null,"spread":false}],"spread":false},{"title":"controller","children":[{"title":"TestController.java <span style='color:#111;'> 3.84KB </span>","children":null,"spread":false}],"spread":false},{"title":"chain1","children":[{"title":"MyFilterImpl2.java <span style='color:#111;'> 698B </span>","children":null,"spread":false},{"title":"MyFilterClient.java <span style='color:#111;'> 659B </span>","children":null,"spread":false},{"title":"MyFilterImpl1.java <span style='color:#111;'> 621B </span>","children":null,"spread":false},{"title":"MyFilter.java <span style='color:#111;'> 283B </span>","children":null,"spread":false},{"title":"Alarm.java <span style='color:#111;'> 1.01KB </span>","children":null,"spread":false},{"title":"MyFilterChain.java <span style='color:#111;'> 1.51KB </span>","children":null,"spread":false}],"spread":false},{"title":"chain3","children":[{"title":"MapHandler.java <span style='color:#111;'> 784B </span>","children":null,"spread":false},{"title":"MapHandler1.java <span style='color:#111;'> 431B </span>","children":null,"spread":false},{"title":"MapHandler2.java <span style='color:#111;'> 431B </span>","children":null,"spread":false},{"title":"MapHandlerClient.java <span style='color:#111;'> 661B </span>","children":null,"spread":false},{"title":"MapHandlerBuilder.java <span style='color:#111;'> 531B </span>","children":null,"spread":false},{"title":"MapHandler3.java <span style='color:#111;'> 431B </span>","children":null,"spread":false}],"spread":false},{"title":"service","children":[{"title":"impl","children":[{"title":"TestServiceImpl.java <span style='color:#111;'> 354B </span>","children":null,"spread":false}],"spread":false},{"title":"TestService.java <span style='color:#111;'> 238B </span>","children":null,"spread":false}],"spread":false},{"title":"job","children":[{"title":"JsonRootBean.java <span style='color:#111;'> 1.16KB </span>","children":null,"spread":false},{"title":"RabbitProducerJob.java <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false}],"spread":false},{"title":"config","children":[{"title":"RabbitConfig.java <span style='color:#111;'> 1.92KB </span>","children":null,"spread":false}],"spread":false},{"title":"chain2","children":[{"title":"MyHandlerImpl2.java <span style='color:#111;'> 384B </span>","children":null,"spread":false},{"title":"MyHandlerChain.java <span style='color:#111;'> 746B </span>","children":null,"spread":false},{"title":"MyHandlerClient.java <span style='color:#111;'> 438B </span>","children":null,"spread":false},{"title":"MyHandlerImpl1.java <span style='color:#111;'> 345B </span>","children":null,"spread":false},{"title":"MyHandler.java <span style='color:#111;'> 1.47KB </span>","children":null,"spread":false}],"spread":false},{"title":"RabbitApplication.java <span style='color:#111;'> 449B </span>","children":null,"spread":false},{"title":"mq","children":[{"title":"consumer","children":[{"title":"RabbitConsumer.java <span style='color:#111;'> 1.24KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"org","children":[{"title":"study","children":[{"title":"RabbitMqApplicationTests.java <span style='color:#111;'> 610B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 3.13KB </span>","children":null,"spread":false}],"spread":true},{"title":"rabbitmq-spring","children":[{"title":"pom.xml <span style='color:#111;'> 640B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}]