下载资源后端资源详情
rocketmq-all-5.3.0-bin-release.zip
大小:88.71MB
价格:45积分
下载量:0
评分:
5.0
上传者:qxmjava
更新日期:2024-07-17

rocketmq-all-5.3.0-bin-release.zip

资源文件列表(大概)

文件名
大小
rocketmq-all-5.3.0-bin-release/benchmark/
-
rocketmq-all-5.3.0-bin-release/benchmark/producer.sh
909B
rocketmq-all-5.3.0-bin-release/benchmark/batchproducer.sh
867B
rocketmq-all-5.3.0-bin-release/benchmark/shutdown.sh
2.46KB
rocketmq-all-5.3.0-bin-release/benchmark/tproducer.sh
891B
rocketmq-all-5.3.0-bin-release/benchmark/runclass.sh
2.76KB
rocketmq-all-5.3.0-bin-release/benchmark/consumer.sh
862B
rocketmq-all-5.3.0-bin-release/bin/
-
rocketmq-all-5.3.0-bin-release/bin/runbroker.cmd
3.22KB
rocketmq-all-5.3.0-bin-release/bin/mqnamesrv
1.44KB
rocketmq-all-5.3.0-bin-release/bin/play.sh
1008B
rocketmq-all-5.3.0-bin-release/bin/dledger/
-
rocketmq-all-5.3.0-bin-release/bin/dledger/fast-try.sh
2.76KB
rocketmq-all-5.3.0-bin-release/bin/os.sh
2.17KB
rocketmq-all-5.3.0-bin-release/bin/setcache.sh
1.13KB
rocketmq-all-5.3.0-bin-release/bin/mqbroker.numanode2
1.34KB
rocketmq-all-5.3.0-bin-release/bin/runbroker.sh
4.77KB
rocketmq-all-5.3.0-bin-release/bin/mqnamesrv.cmd
1.14KB
rocketmq-all-5.3.0-bin-release/bin/mqshutdown.cmd
1.56KB
rocketmq-all-5.3.0-bin-release/bin/mqproxy.cmd
1.13KB
rocketmq-all-5.3.0-bin-release/bin/mqbroker
2.22KB
rocketmq-all-5.3.0-bin-release/bin/mqbroker.numanode1
1.34KB
rocketmq-all-5.3.0-bin-release/bin/mqbroker.numanode0
1.34KB
rocketmq-all-5.3.0-bin-release/bin/mqadmin.cmd
1.08KB
rocketmq-all-5.3.0-bin-release/bin/startfsrv.sh
1.38KB
rocketmq-all-5.3.0-bin-release/bin/mqadmin
1.44KB
rocketmq-all-5.3.0-bin-release/bin/tools.sh
2.1KB
rocketmq-all-5.3.0-bin-release/bin/controller/
-
rocketmq-all-5.3.0-bin-release/bin/controller/fast-try-namesrv-plugin.sh
2.21KB
rocketmq-all-5.3.0-bin-release/bin/controller/fast-try.sh
2.88KB
rocketmq-all-5.3.0-bin-release/bin/controller/fast-try-independent-deployment.cmd
2.17KB
rocketmq-all-5.3.0-bin-release/bin/controller/fast-try.cmd
2.02KB
rocketmq-all-5.3.0-bin-release/bin/controller/fast-try-namesrv-plugin.cmd
2.15KB
rocketmq-all-5.3.0-bin-release/bin/controller/fast-try-independent-deployment.sh
2.22KB
rocketmq-all-5.3.0-bin-release/bin/cleancache.v1.sh
1.09KB
rocketmq-all-5.3.0-bin-release/bin/mqproxy
1.43KB
rocketmq-all-5.3.0-bin-release/bin/mqbroker.cmd
1.13KB
rocketmq-all-5.3.0-bin-release/bin/export.sh
2.46KB
rocketmq-all-5.3.0-bin-release/bin/mqcontroller
1.45KB
rocketmq-all-5.3.0-bin-release/bin/mqbrokercontainer
1.37KB
rocketmq-all-5.3.0-bin-release/bin/mqbroker.numanode3
1.34KB
rocketmq-all-5.3.0-bin-release/bin/tools.cmd
1.51KB
rocketmq-all-5.3.0-bin-release/bin/mqcontroller.cmd
1.15KB
rocketmq-all-5.3.0-bin-release/bin/runserver.sh
4.36KB
rocketmq-all-5.3.0-bin-release/bin/play.cmd
1.12KB
rocketmq-all-5.3.0-bin-release/bin/cachedog.sh
1.62KB
rocketmq-all-5.3.0-bin-release/bin/runserver.cmd
2.81KB
rocketmq-all-5.3.0-bin-release/bin/cleancache.sh
845B
rocketmq-all-5.3.0-bin-release/bin/mqshutdown
2.98KB
rocketmq-all-5.3.0-bin-release/bin/README.md
772B
rocketmq-all-5.3.0-bin-release/conf/
-
rocketmq-all-5.3.0-bin-release/conf/dledger/
-
rocketmq-all-5.3.0-bin-release/conf/dledger/broker-n2.conf
1.13KB
rocketmq-all-5.3.0-bin-release/conf/dledger/broker-n1.conf
1.13KB
rocketmq-all-5.3.0-bin-release/conf/dledger/broker-n0.conf
1.13KB
rocketmq-all-5.3.0-bin-release/conf/rmq.namesrv.logback.xml
5.3KB
rocketmq-all-5.3.0-bin-release/conf/broker.conf
949B
rocketmq-all-5.3.0-bin-release/conf/rmq.controller.logback.xml
8.06KB
rocketmq-all-5.3.0-bin-release/conf/rmq.tools.logback.xml
3.92KB
rocketmq-all-5.3.0-bin-release/conf/rmq-proxy.json
45B
rocketmq-all-5.3.0-bin-release/conf/tools.yml
834B
rocketmq-all-5.3.0-bin-release/conf/rmq.client.logback.xml
2.95KB
rocketmq-all-5.3.0-bin-release/conf/controller/
-
rocketmq-all-5.3.0-bin-release/conf/controller/controller-standalone.conf
889B
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-independent/
-
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-independent/controller-n1.conf
925B
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-independent/controller-n2.conf
925B
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-independent/controller-n0.conf
925B
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-namesrv-plugin/
-
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-namesrv-plugin/namesrv-n1.conf
1014B
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-namesrv-plugin/namesrv-n0.conf
1014B
rocketmq-all-5.3.0-bin-release/conf/controller/cluster-3n-namesrv-plugin/namesrv-n2.conf
1014B
rocketmq-all-5.3.0-bin-release/conf/controller/quick-start/
-
rocketmq-all-5.3.0-bin-release/conf/controller/quick-start/namesrv.conf
920B
rocketmq-all-5.3.0-bin-release/conf/controller/quick-start/broker-n1.conf
1.11KB
rocketmq-all-5.3.0-bin-release/conf/controller/quick-start/broker-n0.conf
1.11KB
rocketmq-all-5.3.0-bin-release/conf/2m-noslave/
-
rocketmq-all-5.3.0-bin-release/conf/2m-noslave/broker-trace.properties
937B
rocketmq-all-5.3.0-bin-release/conf/2m-noslave/broker-a.properties
929B
rocketmq-all-5.3.0-bin-release/conf/2m-noslave/broker-b.properties
929B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-sync/
-
rocketmq-all-5.3.0-bin-release/conf/2m-2s-sync/broker-a.properties
928B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-sync/broker-b-s.properties
922B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-sync/broker-a-s.properties
922B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-sync/broker-b.properties
928B
rocketmq-all-5.3.0-bin-release/conf/rmq.proxy.logback.xml
23.79KB
rocketmq-all-5.3.0-bin-release/conf/plain_acl.yml
1.33KB
rocketmq-all-5.3.0-bin-release/conf/rmq.broker.logback.xml
36.69KB
rocketmq-all-5.3.0-bin-release/conf/container/
-
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/
-
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/broker-a-in-container1.conf
1.24KB
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/broker-container2.conf
1.23KB
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/broker-a-in-container2.conf
1.23KB
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/broker-container1.conf
1.23KB
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/nameserver.conf
811B
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/broker-b-in-container2.conf
1.23KB
rocketmq-all-5.3.0-bin-release/conf/container/2container-2m-2s/broker-b-in-container1.conf
1.23KB
rocketmq-all-5.3.0-bin-release/conf/2m-2s-async/
-
rocketmq-all-5.3.0-bin-release/conf/2m-2s-async/broker-a.properties
929B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-async/broker-b-s.properties
922B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-async/broker-a-s.properties
922B
rocketmq-all-5.3.0-bin-release/conf/2m-2s-async/broker-b.properties
929B
rocketmq-all-5.3.0-bin-release/lib/
-
rocketmq-all-5.3.0-bin-release/lib/jaeger-thrift-1.6.0.jar
688.45KB
rocketmq-all-5.3.0-bin-release/lib/tomcat-annotations-api-8.5.46.jar
12.08KB
rocketmq-all-5.3.0-bin-release/lib/jaeger-tracerresolver-1.6.0.jar
2.52KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-remoting-5.3.0.jar
462.09KB
rocketmq-all-5.3.0-bin-release/lib/grpc-core-1.53.0.jar
714.31KB
rocketmq-all-5.3.0-bin-release/lib/netty-all-4.1.65.Final.jar
4.21MB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-sender-okhttp-1.29.0.jar
23.22KB
rocketmq-all-5.3.0-bin-release/lib/hessian-3.3.6.jar
402.11KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-grpc-netty-codec-haproxy-1.0.0.jar
38.25KB
rocketmq-all-5.3.0-bin-release/lib/jsr305-3.0.2.jar
19.47KB
rocketmq-all-5.3.0-bin-release/lib/commons-lang3-3.12.0.jar
573.63KB
rocketmq-all-5.3.0-bin-release/lib/kotlin-stdlib-jdk7-1.6.20.jar
23.34KB
rocketmq-all-5.3.0-bin-release/lib/bcpkix-jdk15on-1.69.jar
887.71KB
rocketmq-all-5.3.0-bin-release/lib/opentracing-tracerresolver-0.1.8.jar
7.64KB
rocketmq-all-5.3.0-bin-release/lib/commons-io-2.7.jar
269.93KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-otlp-common-1.29.0.jar
103.23KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-slf4j-api-1.0.1.jar
66.15KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-shaded-slf4j-api-bridge-1.0.0.jar
11.61KB
rocketmq-all-5.3.0-bin-release/lib/okio-3.2.0.jar
24.91KB
rocketmq-all-5.3.0-bin-release/lib/perfmark-api-0.25.0.jar
6.57KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-sdk-1.29.0.jar
6.61KB
rocketmq-all-5.3.0-bin-release/lib/libthrift-0.14.1.jar
298.43KB
rocketmq-all-5.3.0-bin-release/lib/caffeine-2.9.3.jar
890.76KB
rocketmq-all-5.3.0-bin-release/lib/bcutil-jdk15on-1.69.jar
351.07KB
rocketmq-all-5.3.0-bin-release/lib/jraft-core-1.3.14.jar
1.22MB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-sdk-extension-autoconfigure-spi-1.29.0.jar
15.94KB
rocketmq-all-5.3.0-bin-release/lib/kotlin-stdlib-common-1.6.20.jar
195.93KB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-boringssl-static-2.0.53.Final-windows-x86_64.jar
976.8KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-sdk-common-1.29.0.jar
41.79KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-sdk-logs-1.29.0.jar
46.2KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-sdk-metrics-1.29.0.jar
251.18KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-tiered-store-5.3.0.jar
142.14KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-logback-classic-1.0.1.jar
917.61KB
rocketmq-all-5.3.0-bin-release/lib/jul-to-slf4j-2.0.6.jar
4.74KB
rocketmq-all-5.3.0-bin-release/lib/hamcrest-2.1.jar
120.22KB
rocketmq-all-5.3.0-bin-release/lib/grpc-netty-shaded-1.53.0.jar
8.91MB
rocketmq-all-5.3.0-bin-release/lib/commons-digester-2.1.jar
192.16KB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-classes-2.0.53.Final.jar
34.06KB
rocketmq-all-5.3.0-bin-release/lib/jctools-core-2.1.1.jar
249.33KB
rocketmq-all-5.3.0-bin-release/lib/grpc-stub-1.53.0.jar
49.72KB
rocketmq-all-5.3.0-bin-release/lib/lz4-java-1.8.0.jar
666.8KB
rocketmq-all-5.3.0-bin-release/lib/okio-jvm-3.4.0.jar
351.65KB
rocketmq-all-5.3.0-bin-release/lib/commons-cli-1.5.0.jar
56.92KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-context-1.29.0.jar
46.08KB
rocketmq-all-5.3.0-bin-release/lib/fastjson2-2.0.43.jar
1.91MB
rocketmq-all-5.3.0-bin-release/lib/javassist-3.20.0-GA.jar
732.99KB
rocketmq-all-5.3.0-bin-release/lib/kotlin-stdlib-jdk8-1.6.20.jar
17.36KB
rocketmq-all-5.3.0-bin-release/lib/grpc-protobuf-1.53.0.jar
4.99KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-prometheus-1.29.0-alpha.jar
37.84KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-acl-5.3.0.jar
61KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-broker-5.3.0.jar
655.4KB
rocketmq-all-5.3.0-bin-release/lib/commons-logging-1.2.jar
60.38KB
rocketmq-all-5.3.0-bin-release/lib/commons-collections-3.2.2.jar
574.55KB
rocketmq-all-5.3.0-bin-release/lib/animal-sniffer-annotations-1.21.jar
3.27KB
rocketmq-all-5.3.0-bin-release/lib/grpc-api-1.53.0.jar
256.31KB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-boringssl-static-2.0.53.Final-osx-aarch_64.jar
843.95KB
rocketmq-all-5.3.0-bin-release/lib/grpc-services-1.53.0.jar
789.5KB
rocketmq-all-5.3.0-bin-release/lib/commons-beanutils-1.9.4.jar
241.13KB
rocketmq-all-5.3.0-bin-release/lib/failureaccess-1.0.1.jar
4.51KB
rocketmq-all-5.3.0-bin-release/lib/grpc-protobuf-lite-1.53.0.jar
7.38KB
rocketmq-all-5.3.0-bin-release/lib/jna-4.2.2.jar
1.08MB
rocketmq-all-5.3.0-bin-release/lib/opentracing-noop-0.33.0.jar
10.29KB
rocketmq-all-5.3.0-bin-release/lib/commons-validator-1.7.jar
185.23KB
rocketmq-all-5.3.0-bin-release/lib/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar
2.15KB
rocketmq-all-5.3.0-bin-release/lib/commons-lang-2.6.jar
277.56KB
rocketmq-all-5.3.0-bin-release/lib/kotlin-stdlib-1.6.20.jar
1.44MB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-common-1.29.0.jar
66.86KB
rocketmq-all-5.3.0-bin-release/lib/metrics-core-4.0.2.jar
95.39KB
rocketmq-all-5.3.0-bin-release/lib/sofa-common-tools-1.0.12.jar
116.82KB
rocketmq-all-5.3.0-bin-release/lib/bcprov-jdk15on-1.69.jar
5.48MB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-logging-otlp-1.29.0.jar
11.54KB
rocketmq-all-5.3.0-bin-release/lib/protobuf-java-util-3.20.1.jar
71.85KB
rocketmq-all-5.3.0-bin-release/lib/annotations-api-6.0.53.jar
14.91KB
rocketmq-all-5.3.0-bin-release/lib/javax.annotation-api-1.3.2.jar
25.96KB
rocketmq-all-5.3.0-bin-release/lib/reflections-0.9.11.jar
127.93KB
rocketmq-all-5.3.0-bin-release/lib/fastjson-1.2.83.jar
655.96KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-filter-5.3.0.jar
83.16KB
rocketmq-all-5.3.0-bin-release/lib/j2objc-annotations-2.8.jar
9.08KB
rocketmq-all-5.3.0-bin-release/lib/guava-32.0.1-jre.jar
2.9MB
rocketmq-all-5.3.0-bin-release/lib/opentracing-util-0.33.0.jar
7.33KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-common-5.3.0.jar
321.52KB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-boringssl-static-2.0.53.Final-osx-x86_64.jar
1.09MB
rocketmq-all-5.3.0-bin-release/lib/dledger-0.3.1.2.jar
174.8KB
rocketmq-all-5.3.0-bin-release/lib/concurrentlinkedhashmap-lru-1.4.2.jar
113.83KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-container-5.3.0.jar
47KB
rocketmq-all-5.3.0-bin-release/lib/disruptor-3.3.7.jar
83.57KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-client-5.3.0.jar
532.06KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-srvutil-5.3.0.jar
18.19KB
rocketmq-all-5.3.0-bin-release/lib/commons-codec-1.13.jar
336.27KB
rocketmq-all-5.3.0-bin-release/lib/checker-qual-3.33.0.jar
218.73KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-extension-incubator-1.29.0-alpha.jar
7.47KB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-boringssl-static-2.0.53.Final-linux-x86_64.jar
1.17MB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-namesrv-5.3.0.jar
64.74KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-api-events-1.29.0-alpha.jar
5.89KB
rocketmq-all-5.3.0-bin-release/lib/gson-2.9.0.jar
243.43KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-sdk-trace-1.29.0.jar
114.29KB
rocketmq-all-5.3.0-bin-release/lib/protobuf-java-3.20.1.jar
1.61MB
rocketmq-all-5.3.0-bin-release/lib/annotations-13.0.jar
17.13KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-auth-5.3.0.jar
112.61KB
rocketmq-all-5.3.0-bin-release/lib/okhttp-4.11.0.jar
768.52KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-proto-2.0.3.jar
827.7KB
rocketmq-all-5.3.0-bin-release/lib/tomcat-embed-core-8.5.46.jar
3.06MB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-boringssl-static-2.0.53.Final.jar
3.17KB
rocketmq-all-5.3.0-bin-release/lib/openmessaging-api-0.3.1-alpha.jar
23.12KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-proxy-5.3.0.jar
452.08KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-store-5.3.0.jar
601.1KB
rocketmq-all-5.3.0-bin-release/lib/slf4j-api-2.0.3.jar
59.97KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-controller-5.3.0.jar
148.1KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-otlp-1.29.0.jar
58.37KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-api-1.29.0.jar
134.75KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-semconv-1.29.0-alpha.jar
38.73KB
rocketmq-all-5.3.0-bin-release/lib/annotations-4.1.1.4.jar
3.05KB
rocketmq-all-5.3.0-bin-release/lib/snakeyaml-2.0.jar
326.96KB
rocketmq-all-5.3.0-bin-release/lib/jackson-core-2.15.2.jar
536.33KB
rocketmq-all-5.3.0-bin-release/lib/disruptor-1.2.10.jar
131.78KB
rocketmq-all-5.3.0-bin-release/lib/netty-tcnative-boringssl-static-2.0.53.Final-linux-aarch_64.jar
940.93KB
rocketmq-all-5.3.0-bin-release/lib/awaitility-4.1.0.jar
90.38KB
rocketmq-all-5.3.0-bin-release/lib/opentelemetry-exporter-logging-1.29.0.jar
10.86KB
rocketmq-all-5.3.0-bin-release/lib/error_prone_annotations-2.14.0.jar
15.65KB
rocketmq-all-5.3.0-bin-release/lib/grpc-context-1.53.0.jar
29.87KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-rocksdb-1.0.2.jar
28.59MB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-example-5.3.0.jar
167.23KB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-openmessaging-5.3.0.jar
51.32KB
rocketmq-all-5.3.0-bin-release/lib/proto-google-common-protos-2.9.0.jar
1.69MB
rocketmq-all-5.3.0-bin-release/lib/zstd-jni-1.5.2-2.jar
5.15MB
rocketmq-all-5.3.0-bin-release/lib/rocketmq-tools-5.3.0.jar
388.56KB
rocketmq-all-5.3.0-bin-release/lib/bolt-1.6.4.jar
273.51KB
rocketmq-all-5.3.0-bin-release/LICENSE
16.92KB
rocketmq-all-5.3.0-bin-release/NOTICE
1.31KB
rocketmq-all-5.3.0-bin-release/README.md
11.98KB

资源内容介绍

RocketMQ是一款阿里巴巴开源的消息中间件
## Apache RocketMQ[![Build Status][maven-build-image]][maven-build-url][![CodeCov][codecov-image]][codecov-url][![Maven Central][maven-central-image]][maven-central-url][![Release][release-image]][release-url][![License][license-image]][license-url][![Average Time to Resolve An Issue][percentage-of-issues-still-open-image]][percentage-of-issues-still-open-url][![Percentage of Issues Still Open][average-time-to-resolve-an-issue-image]][average-time-to-resolve-an-issue-url][![Twitter Follow][twitter-follow-image]][twitter-follow-url]**[Apache RocketMQ](https://rocketmq.apache.org) is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.**It offers a variety of features:* Messaging patterns including publish/subscribe, request/reply and streaming* Financial grade transactional message* Built-in fault tolerance and high availability configuration options base on [DLedger Controller](docs/en/controller/quick_start.md)* Built-in message tracing capability, also support opentracing* Versatile big-data and streaming ecosystem integration* Message retroactivity by time or offset* Reliable FIFO and strict ordered messaging in the same queue* Efficient pull and push consumption model* Million-level message accumulation capacity in a single queue* Multiple messaging protocols like gRPC, MQTT, JMS and OpenMessaging* Flexible distributed scale-out deployment architecture* Lightning-fast batch message exchange system* Various message filter mechanics such as SQL and Tag* Docker images for isolated testing and cloud isolated clusters* Feature-rich administrative dashboard for configuration, metrics and monitoring* Authentication and authorization* Free open source connectors, for both sources and sinks* Lightweight real-time computing----------## Quick StartThis paragraph guides you through steps of installing RocketMQ in different ways.For local development and testing, only one instance will be created for each component.### Run RocketMQ locallyRocketMQ runs on all major operating systems and requires only a Java JDK version 8 or higher to be installed.To check, run `java -version`:```shell$ java -versionjava version "1.8.0_121"```For Windows users, click [here](https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip) to download the 5.2.0 RocketMQ binary release,unpack it to your local disk, such as `D:\rocketmq`.For macOS and Linux users, execute following commands:```shell# Download release from the Apache mirror$ wget https://dist.apache.org/repos/dist/release/rocketmq/5.2.0/rocketmq-all-5.2.0-bin-release.zip# Unpack the release$ unzip rocketmq-all-5.2.0-bin-release.zip```Prepare a terminal and change to the extracted `bin` directory:```shell$ cd rocketmq-all-5.2.0-bin-release/bin```**1) Start NameServer**NameServer will be listening at `0.0.0.0:9876`, make sure that the port is not used by others on the local machine, and then do as follows.For macOS and Linux users:```shell### start Name Server$ nohup sh mqnamesrv &### check whether Name Server is successfully started$ tail -f ~/logs/rocketmqlogs/namesrv.logThe Name Server boot success...```For Windows users, you need set environment variables first:- From the desktop, right click the Computer icon.- Choose Properties from the context menu.- Click the Advanced system settings link.- Click Environment Variables.- Add Environment `ROCKETMQ_HOME="D:\rocketmq"`. Then change directory to rocketmq, type and run:```shell$ mqnamesrv.cmdThe Name Server boot success...```**2) Start Broker**For macOS and Linux users:```shell### start Broker$ nohup sh bin/mqbroker -n localhost:9876 &### check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is broker-a$ tail -f ~/logs/rocketmqlogs/broker.logThe broker[broker-a, 192.169.1.2:10911] boot success...```For Windows users:```shell$ mqbroker.cmd -n localhost:9876The broker[broker-a, 192.169.1.2:10911] boot success...```### Run RocketMQ in DockerYou can run RocketMQ on your own machine within Docker containers,`host` network will be used to expose listening port in the container.**1) Start NameServer**```shell$ docker run -it --net=host apache/rocketmq ./mqnamesrv```**2) Start Broker**```shell$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876```### Run RocketMQ in KubernetesYou can also run a RocketMQ cluster within a Kubernetes cluster using [RocketMQ Operator](https://github.com/apache/rocketmq-operator).Before your operations, make sure that `kubectl` and related kubeconfig file installed on your machine.**1) Install CRDs**```shell### install CRDs$ git clone https://github.com/apache/rocketmq-operator$ cd rocketmq-operator && make deploy### check whether CRDs is successfully installed$ kubectl get crd | grep rocketmq.apache.orgbrokers.rocketmq.apache.org 2022-05-12T09:23:18Zconsoles.rocketmq.apache.org 2022-05-12T09:23:19Znameservices.rocketmq.apache.org 2022-05-12T09:23:18Ztopictransfers.rocketmq.apache.org 2022-05-12T09:23:19Z### check whether operator is running$ kubectl get pods | grep rocketmq-operatorrocketmq-operator-6f65c77c49-8hwmj 1/1 Running 0 93s```**2) Create Cluster Instance**```shell### create RocketMQ cluster resource$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml### check whether cluster resources is running$ kubectl get stsNAME READY AGEbroker-0-master 1/1 107mbroker-0-replica-1 1/1 107mname-service 1/1 107m```---## Apache RocketMQ Community* [RocketMQ Streams](https://github.com/apache/rocketmq-streams): A lightweight stream computing engine based on Apache RocketMQ.* [RocketMQ Flink](https://github.com/apache/rocketmq-flink): The Apache RocketMQ connector of Apache Flink that supports source and sink connector in data stream and Table.* [RocketMQ APIs](https://github.com/apache/rocketmq-apis): RocketMQ protobuf protocol.* [RocketMQ Clients](https://github.com/apache/rocketmq-clients): gRPC/protobuf-based RocketMQ clients.* RocketMQ Remoting-based Clients - [RocketMQ Client CPP](https://github.com/apache/rocketmq-client-cpp) - [RocketMQ Client Go](https://github.com/apache/rocketmq-client-go) - [RocketMQ Client Python](https://github.com/apache/rocketmq-client-python) - [RocketMQ Client Nodejs](https://github.com/apache/rocketmq-client-nodejs)* [RocketMQ Spring](https://github.com/apache/rocketmq-spring): A project which helps developers quickly integrate Apache RocketMQ with Spring Boot.* [RocketMQ Exporter](https://github.com/apache/rocketmq-exporter): An Apache RocketMQ exporter for Prometheus.* [RocketMQ Operator](https://github.com/apache/rocketmq-operator): Providing a way to run an Apache RocketMQ cluster on Kubernetes.* [RocketMQ Docker](https://github.com/apache/rocketmq-docker): The Git repo of the Docker Image for Apache RocketMQ.* [RocketMQ Dashboard](https://github.com/apache/rocketmq-dashboard): Operation and maintenance console of Apache RocketMQ.* [RocketMQ Connect](https://github.com/apache/rocketmq-connect): A tool for scalably and reliably streaming data between Apache RocketMQ and other systems.* [RocketMQ MQTT](https://github.com/apache/rocketmq-mqtt): A new MQTT protocol architecture model, based on which Apache RocketMQ can better support messages from terminals such as IoT devices and Mobile APP.* [RocketMQ EventBridge](https://github.com/apache/rocketmq-eventbridge): EventBridge make it easier to build a event-driven application.* [RocketMQ Incubating Community Projects](https://github.com/apache/rocketmq-externals): Incubator community projects of Apache RocketMQ, incl

用户评论 (0)

发表评论

captcha