RocketMQ使用实例
资源文件列表
rocketmq-demo1/.gitignore , 395
rocketmq-demo1/.idea/compiler.xml , 640
rocketmq-demo1/.idea/encodings.xml , 172
rocketmq-demo1/.idea/inspectionProfiles/Project_Default.xml , 550
rocketmq-demo1/.idea/libraries/Maven__ch_qos_logback_logback_classic_1_2_3.xml , 568
rocketmq-demo1/.idea/libraries/Maven__ch_qos_logback_logback_core_1_2_3.xml , 547
rocketmq-demo1/.idea/libraries/Maven__com_alibaba_fastjson_1_2_51.xml , 514
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_classmate_1_4_0.xml , 522
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_annotations_2_9_10.xml , 651
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_core_2_9_10.xml , 602
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_jackson_core_jackson_databind_2_9_10_5.xml , 644
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_jackson_datatype_jackson_datatype_jdk8_2_9_10.xml , 681
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_jackson_datatype_jackson_datatype_jsr310_2_9_10.xml , 695
rocketmq-demo1/.idea/libraries/Maven__com_fasterxml_jackson_module_jackson_module_parameter_names_2_9_10.xml , 736
rocketmq-demo1/.idea/libraries/Maven__com_google_guava_guava_20_0.xml , 499
rocketmq-demo1/.idea/libraries/Maven__com_jayway_jsonpath_json_path_2_4_0.xml , 546
rocketmq-demo1/.idea/libraries/Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml , 700
rocketmq-demo1/.idea/libraries/Maven__io_micrometer_micrometer_core_1_1_16.xml , 571
rocketmq-demo1/.idea/libraries/Maven__io_netty_netty_all_4_1_51_Final.xml , 551
rocketmq-demo1/.idea/libraries/Maven__io_netty_netty_tcnative_boringssl_static_2_0_31_Final.xml , 705
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_core_2_9_2.xml , 553
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_schema_2_9_2.xml , 567
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_spi_2_9_2.xml , 546
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_spring_web_2_9_2.xml , 595
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_swagger2_2_9_2.xml , 581
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_swagger_common_2_9_2.xml , 623
rocketmq-demo1/.idea/libraries/Maven__io_springfox_springfox_swagger_ui_2_9_2.xml , 595
rocketmq-demo1/.idea/libraries/Maven__io_swagger_swagger_annotations_1_5_20.xml , 587
rocketmq-demo1/.idea/libraries/Maven__io_swagger_swagger_models_1_5_20.xml , 552
rocketmq-demo1/.idea/libraries/Maven__javax_annotation_javax_annotation_api_1_3_2.xml , 611
rocketmq-demo1/.idea/libraries/Maven__javax_validation_validation_api_2_0_1_Final.xml , 611
rocketmq-demo1/.idea/libraries/Maven__junit_junit_4_11.xml , 455
rocketmq-demo1/.idea/libraries/Maven__net_bytebuddy_byte_buddy_1_9_16.xml , 536
rocketmq-demo1/.idea/libraries/Maven__net_bytebuddy_byte_buddy_agent_1_9_16.xml , 578
rocketmq-demo1/.idea/libraries/Maven__net_minidev_accessors_smart_1_2.xml , 542
rocketmq-demo1/.idea/libraries/Maven__net_minidev_json_smart_2_3.xml , 507
rocketmq-demo1/.idea/libraries/Maven__org_apache_commons_commons_lang3_3_8_1.xml , 570
rocketmq-demo1/.idea/libraries/Maven__org_apache_logging_log4j_log4j_api_2_11_2.xml , 573
rocketmq-demo1/.idea/libraries/Maven__org_apache_logging_log4j_log4j_to_slf4j_2_11_2.xml , 608
rocketmq-demo1/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_client_4_5_2.xml , 588
rocketmq-demo1/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_common_4_5_2.xml , 588
rocketmq-demo1/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_logging_4_5_2.xml , 595
rocketmq-demo1/.idea/libraries/Maven__org_apache_rocketmq_rocketmq_remoting_4_5_2.xml , 602
rocketmq-demo1/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_core_9_0_37.xml , 625
rocketmq-demo1/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_el_9_0_37.xml , 611
rocketmq-demo1/.idea/libraries/Maven__org_apache_tomcat_embed_tomcat_embed_websocket_9_0_37.xml , 660
rocketmq-demo1/.idea/libraries/Maven__org_assertj_assertj_core_3_11_1.xml , 542
rocketmq-demo1/.idea/libraries/Maven__org_hamcrest_hamcrest_core_1_3.xml , 532
rocketmq-demo1/.idea/libraries/Maven__org_hamcrest_hamcrest_library_1_3.xml , 553
rocketmq-demo1/.idea/libraries/Maven__org_hdrhistogram_HdrHistogram_2_1_9.xml , 555
rocketmq-demo1/.idea/libraries/Maven__org_hibernate_validator_hibernate_validator_6_0_20_Final.xml , 681
rocketmq-demo1/.idea/libraries/Maven__org_jboss_logging_jboss_logging_3_3_3_Final.xml , 608
rocketmq-demo1/.idea/libraries/Maven__org_latencyutils_LatencyUtils_2_0_3.xml , 555
rocketmq-demo1/.idea/libraries/Maven__org_mapstruct_mapstruct_1_2_0_Final.xml , 564
rocketmq-demo1/.idea/libraries/Maven__org_mockito_mockito_core_2_23_4.xml , 542
rocketmq-demo1/.idea/libraries/Maven__org_objenesis_objenesis_2_6.xml , 508
rocketmq-demo1/.idea/libraries/Maven__org_ow2_asm_asm_5_0_4.xml , 472
rocketmq-demo1/.idea/libraries/Maven__org_skyscreamer_jsonassert_1_5_0.xml , 537
rocketmq-demo1/.idea/libraries/Maven__org_slf4j_jul_to_slf4j_1_7_30.xml , 534
rocketmq-demo1/.idea/libraries/Maven__org_slf4j_slf4j_api_1_7_30.xml , 513
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_2_1_16_RELEASE.xml , 643
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_actuator_2_1_16_RELEASE.xml , 706
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_actuator_autoconfigure_2_1_16_RELEASE.xml , 804
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_autoconfigure_2_1_16_RELEASE.xml , 741
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_2_1_16_RELEASE.xml , 699
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_actuator_2_1_16_RELEASE.xml , 762
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_json_2_1_16_RELEASE.xml , 734
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_logging_2_1_16_RELEASE.xml , 755
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_test_2_1_16_RELEASE.xml , 734
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_tomcat_2_1_16_RELEASE.xml , 748
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_starter_web_2_1_16_RELEASE.xml , 727
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_2_1_16_RELEASE.xml , 678
rocketmq-demo1/.idea/libraries/Maven__org_springframework_boot_spring_boot_test_autoconfigure_2_1_16_RELEASE.xml , 776
rocketmq-demo1/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_core_1_2_0_RELEASE.xml , 693
rocketmq-demo1/.idea/libraries/Maven__org_springframework_plugin_spring_plugin_metadata_1_2_0_RELEASE.xml , 721
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_aop_5_1_17_RELEASE.xml , 616
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_beans_5_1_17_RELEASE.xml , 630
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_context_5_1_17_RELEASE.xml , 644
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_core_5_1_17_RELEASE.xml , 623
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_expression_5_1_17_RELEASE.xml , 665
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_jcl_5_1_17_RELEASE.xml , 616
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_test_5_1_17_RELEASE.xml , 623
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_webmvc_5_1_17_RELEASE.xml , 637
rocketmq-demo1/.idea/libraries/Maven__org_springframework_spring_web_5_1_17_RELEASE.xml , 616
rocketmq-demo1/.idea/libraries/Maven__org_xmlunit_xmlunit_core_2_6_4.xml , 535
rocketmq-demo1/.idea/libraries/Maven__org_yaml_snakeyaml_1_23.xml , 495
rocketmq-demo1/.idea/misc.xml , 439
rocketmq-demo1/.idea/modules.xml , 268
rocketmq-demo1/.idea/workspace.xml , 72665
rocketmq-demo1/.mvn/wrapper/maven-wrapper.jar , 50710
rocketmq-demo1/.mvn/wrapper/maven-wrapper.properties , 218
rocketmq-demo1/.mvn/wrapper/MavenWrapperDownloader.java , 4942
rocketmq-demo1/pom.xml , 2574
rocketmq-demo1/rocketmq-demo1.iml , 10145
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/consumer/ConsumerDemo.java , 2037
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/filter/ConsumerFilterDemo.java , 2083
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/filter/SyncProducerFilter.java , 1406
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/order/OrderConsumer.java , 1723
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/order/OrderProducer.java , 1235
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/sendmsg/AsyncProducer.java , 1847
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/sendmsg/SyncProducer.java , 1454
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/SyncProducer.java , 1321
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/topic/TopicDemo.java , 740
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/transaction/TransactionConsumer.java , 1741
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/transaction/TransactionListenerImpl.java , 1927
rocketmq-demo1/src/main/java/cn/hdcf/rocketmq/transaction/TransactionProducer.java , 926
rocketmq-demo1/src/main/java/com/hdcf/it/demo/basedemo/RocketMQAsyProducer.java , 1936
rocketmq-demo1/src/main/java/com/hdcf/it/demo/basedemo/RocketMQProduer.java , 1876
rocketmq-demo1/src/main/java/com/hdcf/it/demo/basedemo/RocketMQPullConsumer.java , 3225
rocketmq-demo1/src/main/java/com/hdcf/it/demo/basedemo/RocketMQPullConsumer2.java , 437
rocketmq-demo1/src/main/java/com/hdcf/it/demo/basedemo/RocketMQPushConsumer.java , 2661
rocketmq-demo1/src/main/java/com/hdcf/it/demo/controller/HelloWorldController.java , 613
rocketmq-demo1/src/main/java/com/hdcf/it/demo/DemoApplication.java , 305
rocketmq-demo1/src/main/java/com/hdcf/it/demo/single/SRocketMQConsumer.java , 2265
rocketmq-demo1/src/main/java/com/hdcf/it/demo/single/SRocketMQProducer.java , 1587
rocketmq-demo1/src/main/java/com/hdcf/it/demo/sync/SyncConsumer.java , 2156
rocketmq-demo1/src/main/java/com/hdcf/it/demo/sync/SyncProducer.java , 1776
rocketmq-demo1/src/main/java/com/hdcf/it/demo/transaction/TransactionConsumer.java , 2074
rocketmq-demo1/src/main/java/com/hdcf/it/demo/transaction/TransactionListenerLocal.java , 1694
rocketmq-demo1/src/main/java/com/hdcf/it/demo/transaction/TransactionProducer.java , 1857
rocketmq-demo1/src/main/resources/application.properties , 123
rocketmq-demo1/target/classes/application.properties , 163
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/consumer/ConsumerDemo$1.class , 2559
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/consumer/ConsumerDemo.class , 1359
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/filter/ConsumerFilterDemo$1.class , 2577
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/filter/ConsumerFilterDemo.class , 1604
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/filter/SyncProducerFilter.class , 2491
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/order/OrderConsumer$1.class , 2616
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/order/OrderConsumer.class , 1092
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/order/OrderProducer.class , 3126
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/sendmsg/AsyncProducer$1.class , 1746
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/sendmsg/AsyncProducer.class , 1740
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/sendmsg/SyncProducer.class , 2461
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/SyncProducer.class , 1830
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/topic/TopicDemo.class , 932
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/transaction/TransactionConsumer$1.class , 2344
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/transaction/TransactionConsumer.class , 1146
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/transaction/TransactionListenerImpl.class , 2462
rocketmq-demo1/target/classes/cn/hdcf/rocketmq/transaction/TransactionProducer.class , 1572
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQAsyProducer$1.class , 1085
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQAsyProducer.class , 2049
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQProduer.class , 2738
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQPullConsumer$1.class , 930
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQPullConsumer.class , 4551
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQPullConsumer2.class , 702
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQPushConsumer$1.class , 2609
rocketmq-demo1/target/classes/com/hdcf/it/demo/basedemo/RocketMQPushConsumer.class , 1963
rocketmq-demo1/target/classes/com/hdcf/it/demo/controller/HelloWorldController.class , 1096
rocketmq-demo1/target/classes/com/hdcf/it/demo/DemoApplication.class , 703
rocketmq-demo1/target/classes/com/hdcf/it/demo/single/SRocketMQConsumer$1.class , 2828
rocketmq-demo1/target/classes/com/hdcf/it/demo/single/SRocketMQConsumer.class , 1702
最多只能显示150条信息!