DeFiBus=RPC+MQ，是基于开源消息中间件打造的安全可控的分布式金融级消息总线资源-CSDN文库

共199个文件

java：108个

png：20个

xml：15个

版权申诉

服务器应用

141 浏览量 2023-06-21 12:15:22 上传评论收藏 1.11MB ZIP 举报

资源推荐

资源详情

资源评论

收起资源包目录

DeFiBus=RPC+MQ，是基于开源消息中间件打造的安全可控的分布式金融级消息总线（199个子文件）

gradlew.bat 2KB

runnamesrv.cmd 2KB

runbroker.cmd 2KB

runadmin.cmd 2KB

stop.cmd 1KB

.gitignore 167B

.gitignore 162B

.gitignore 147B

.gitignore 139B

build.gradle 8KB

build.gradle 1KB

settings.gradle 1KB

build.gradle 1KB

build.gradle 971B

gradlew 5KB

gradle-wrapper.jar 58KB

DeFiBusProducerImpl.java 25KB

DeFiReplyMessageProcessor.java 22KB

AdjustQueueNumStrategy.java 20KB

ConsumeQueueManager.java 18KB

DeFiConsumerManager.java 18KB

DeFiBusClientAPIImpl.java 17KB

DeFiBrokerController.java 17KB

DeFiAdminBrokerProcessor.java 15KB

DeFiBusProducerTest.java 14KB

HealthyMessageQueueSelectorTest.java 12KB

DeFiBusBrokerStartup.java 11KB

DeFiPullMessageProcessor.java 11KB

ConsumeQueueAccessLockManager.java 10KB

DeFiBusMessageListenerConcurrentlyOnceTest.java 10KB

DeFiBusMessageListenerConcurrentlyTest.java 10KB

DeFiBusClientConfig.java 10KB

HealthyMessageQueueSelector.java 10KB

DeFiBusAdminStartup.java 10KB

DeFiBusPushConsumer.java 10KB

DeFiTopicConfigManager.java 10KB

DeFiBusClientAPIImplTest.java 10KB

DeFiBusClientInstance.java 9KB

DeFiBusProducer.java 9KB

UpdateTopicPermSubCommand.java 9KB

AllocateMessageQueueByIDCTest.java 9KB

QueueListeningMonitor.java 9KB

DeFiSendMessageProcessor.java 9KB

MessageRedirectManager.java 8KB

BrokerFuseTest.java 8KB

AllocateMessageQueueByIDC.java 8KB

ClientFuseTest.java 8KB

DeFiClientManageProcessorTest.java 7KB

DeFiBusBrokerConfig.java 7KB

DeFiBusClientRemotingProcessor.java 7KB

DeFiReplyMessageProcessorTest.java 7KB

DeFiAdminBrokerProcessorTest.java 7KB

DeFiBusPullMessageService.java 7KB

DeFiPullMessageProcessorTest.java 6KB

DeFiSendMessageProcessorTest.java 6KB

DeFiConsumerGroupInfo.java 6KB

DeFiClientManageProcessor.java 5KB

ConsumeQueueManagerTest.java 5KB

ReflectUtil.java 5KB

PluginStoreStatService.java 5KB

DeFiConsumerManagerTest.java 5KB

DeFiBusClientInstanceTest.java 5KB

ResponseConsumer.java 5KB

DeFiProducerManager.java 5KB

DeFiPluginMessageStore.java 4KB

DeFiBusMessageListenerConcurrentlyWithReply.java 4KB

ReplyMessageRequestHeader.java 4KB

DeFiProducerManagerTest.java 4KB

MessageRedirectManagerTest.java 4KB

DeFiBusMessageListenerConcurrently.java 4KB

DeFiBusBroker2Client.java 4KB

ConsumeQueueWaterMark.java 4KB

DeFiBusMessageListenerConcurrentlyOnce.java 3KB

DeFiPluginMessageStoreTest.java 3KB

DeFiBusTopicConfig.java 3KB

DeFiBusClientManager.java 3KB

RRResponseFutureTest.java 3KB

SubConsumer.java 3KB

ResponseConsumerAutoReply.java 3KB

ClientRebalanceResultManager.java 3KB

RequestProducer.java 3KB

AdjustQueueNumStrategyTest.java 3KB

DeFiBusConstant.java 2KB

DeFiBusVersion.java 2KB

QueueListeningMonitorTest.java 2KB

DeFiBusClientUtil.java 2KB

DeFiBusCLientUtilTest.java 2KB

MessageQueueHealthManager.java 2KB

PubProducer.java 2KB

RRResponseFuture.java 2KB

DeFiBusConsumeStats.java 2KB

DeFiBusConsumeStatsTest.java 2KB

DeFiBusClientHookFactoryTest.java 2KB

MessageQueueHealthManagerTest.java 2KB

DeFiBrokerControllerTest.java 2KB

共 199 条

--------------------------VERSION 1.0.0----------------------------- 1. implement of sync-request producer. 2. dark launch 3. circuit breaker mechanism 4. invoke service nearby 5. (tong cheng duo huo) 6. dynamic adjust queue 7. isolation mechanism 8. fault tolerant

评论收藏

内容反馈

版权申诉