MessagePipe分布式消息顺序消费管道 v1.0
84 浏览量
2020-09-28
15:40:19
上传
评论
收藏 95KB ZIP 举报
20200830092922449_easck.com.zip （74个子文件） 
易采源码下载说明.txt 310B
message-pipe 
.gitignore 329B README.md 2KB pom.xml 5KB .github workflows deploy.yml 1KB LICENSE 11KB message-pipe-server pom.xml 2KB src main java org minbox framework message pipe server MessagePipe.java 3KB MessagePipeFactoryBean.java 1KB manager MessagePipeManager.java 560B AbstractMessagePipeManager.java 5KB DefaultMessagePipeManager.java 744B lb support RandomWeightedStrategy.java 2KB LoadBalanceNode.java 1KB ClientLoadBalanceStrategy.java 688B exception ExceptionHandler.java 504B ConsoleExceptionHandler.java 444B ClientManager.java 5KB ClientInteractiveService.java 5KB ClientExpiredExecutor.java 4KB config ServerConfiguration.java 904B MessagePipeConfiguration.java 3KB MessagePipeServerApplication.java 3KB distribution RequestIdGenerator.java 309B MessageDistributionExecutor.java 7KB RequestIdSequenceGenerator.java 722B LockNames.java 659B message-pipe-spring-context pom.xml 2KB src main java org minbox framework message pipe spring utils MessagePipeBeanUtils.java 5KB annotation server EnableMessagePipeServer.java 651B MessagePipeServerImportBeanDefinitionRegistrar.java 716B client EnableMessagePipeClient.java 599B MessagePipeClientImportBeanDefinitionRegistrar.java 716B message-pipe-client pom.xml 2KB src main java org minbox framework message pipe client ServerManager.java 3KB MessagePipeClientApplication.java 3KB config ClientConfiguration.java 1KB ReceiveMessageService.java 3KB process MessageProcessorManager.java 2KB MessageProcessor.java 681B connect ConnectServerExecutor.java 7KB message-pipe-core pom.xml 3KB src main java org minbox framework message pipe core information ServerInformation.java 760B ClientInformation.java 1KB untis StringUtils.java 382B InternetAddressUtils.java 517B exception MessagePipeException.java 456B thread MessagePipeThreadFactory.java 2KB transport ClientHeartBeatResponseBody.java 590B MessageRequestBody.java 693B MessageResponseBody.java 733B ClientRegisterResponseBody.java 570B MessageResponseStatus.java 294B Message.java 612B ClientStatus.java 160B grpc MessageServiceGrpc.java 8KB ClientServiceGrpc.java 10KB proto MessageResponse.java 15KB ClientRegisterRequest.java 20KB ClientResponse.java 15KB ClientHeartBeatRequestOrBuilder.java 624B MessageProto.java 3KB ClientResponseOrBuilder.java 532B MessageResponseOrBuilder.java 529B MessageRequest.java 15KB ClientServiceProto.java 5KB ClientHeartBeatRequest.java 17KB ClientRegisterRequestOrBuilder.java 836B MessageRequestOrBuilder.java 527B converter MessageConverter.java 503B proto ClientService.proto 626B MessageService.proto 348B 易采源码下载.url 344B 下载说明.htm 3KB资源评论
