Tarzan:可靠事件系统，Tarzan取自电影《人猿泰山》的英文名，用于保证消息生产者的消息被可靠投递
需积分: 17 155 浏览量
2021-05-14
04:29:31
上传
评论
收藏 1.14MB ZIP 举报
Tarzan:可靠事件系统，Tarzan取自电影《人猿泰山》的英文名，用于保证消息生产者的消息被可靠投递 （275个子文件） 
deploy.bat 119B .gitignore 51B NettyRpcClient.java 24KB NettyRpcAbstract.java 20KB RedisComponent.java 18KB NettyRpcServer.java 16KB RpcCommand.java 14KB ExampleClient.java 14KB RocketMQHandler.java 13KB ServerController.java 10KB AbstractZooKeeperRegistry.java 10KB ClientManager.java 9KB MessageAggregatePlanService.java 9KB ClientController.java 9KB RocketMQStoreService.java 9KB MessageAggregateScheduledService.java 8KB ClusterClient.java 8KB AbstractMQMessageSender.java 8KB MessageResendService.java 8KB AdminZooKeeperDiscovery.java 8KB TransactionCheckService.java 7KB ThreadLocalRandom.java 7KB DateUtils.java 7KB ServerBenchMarkTest.java 6KB IdWorker.java 6KB RocketMQMessageSender.java 6KB ServerZooKeeperRegistry.java 6KB ClassUtils.java 6KB RecordConsumeProcessor.java 6KB SendMessageProcessor.java 6KB AdminRequestProcessor.java 5KB RocketMQClientTest.java 5KB ServerRequestProcessor.java 5KB AbstractMQConsumeRecorder.java 5KB ClientManageProcessor.java 5KB DefaultTransactionCheckExecutor.java 5KB ServerStartup.java 5KB ServerConfig.java 5KB RocketMQMessageNotifier.java 5KB ConcurrentHashSet.java 4KB MessageConsumeService.java 4KB MessageConsume.java 4KB ServerManager.java 4KB ResponseFuture.java 4KB ServerRegistryTest.java 4KB TarzanTestCase.java 4KB ServiceThread.java 4KB ServerAddress.java 4KB NetworkUtils.java 4KB MQMessage.java 4KB ClientAddress.java 4KB MessageToSendJob.java 4KB FailoverClusterClient.java 4KB ClientZooKeeperRegistry.java 4KB ClientChannelInfo.java 4KB ExampleClientTest.java 3KB MessageAggregatePlan.java 3KB MessageToCheckJob.java 3KB ToCheckMessageService.java 3KB ToSendMessageService.java 3KB ClientChannelManageService.java 3KB RocketMQMessageTest.java 3KB MessageConsumeQuery.java 3KB ClientConfig.java 3KB AbstractMQMessageNotifier.java 3KB RecordConsumeHeader.java 3KB QueryMessageProcessor.java 3KB NettyServerConfig.java 3KB RpcCommandBuilder.java 3KB RpcHelper.java 3KB WheelTimer.java 3KB MQMessageQuery.java 3KB NettyClientConfig.java 3KB PagingParam.java 3KB Result.java 3KB RpcServer.java 3KB MQMessageHandlerFactory.java 3KB ToCheckMessage.java 3KB ToSendMessage.java 3KB TableShardingTool.java 2KB NettyDecoder.java 2KB MessageAggregateTest.java 2KB MessageAggregatePlanQuery.java 2KB MessageResult.java 2KB RpcCommandTest.java 2KB RocketMQTableUtils.java 2KB MQConsume.java 2KB ProtostuffSerializer.java 2KB NettyEncoder.java 2KB RocketMQBody.java 2KB TarzanTestConsumer.java 2KB FailfastClusterClient.java 2KB StoreService.java 2KB ConfigManager.java 2KB TransactionMessageHeader.java 2KB Constants.java 2KB IdGenerateTest.java 2KB TestWheelTimer.java 2KB WheelTask.java 2KB RpcClient.java 2KB共 275 条
- 1
- 2
- 3
资源评论
