登录注册

Jar文件详情内容

aeron-all-1.9.3-sources.jar

所在目录：/io/aeron/aeron-all/1.9.3 查看aeron-all所有版本文件

组织ID:	io.aeron
项目ID:	aeron-all
版本:	1.9.3
最后修改时间:	2018-12-10 12:44:46
包类型:	java-source (源码)
大小:	742.13KB

Maven引入代码:	`<dependency> <groupId>io.aeron</groupId> <artifactId>aeron-all</artifactId> <version>1.9.3</version> <classifier>sources</classifier> <type>java-source</type> </dependency>`
Gradle引入代码:	`io.aeron:aeron-all:1.9.3`
下载Jar包:	aeron-all-1.9.3-sources.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF io/aeron/ErrorCode.java io/aeron/LogBuffersFactory.java io/aeron/ImageFragmentAssembler.java io/aeron/Image.java io/aeron/ReservedValueSupplier.java io/aeron/Publication.java io/aeron/AvailableCounterHandler.java io/aeron/ChannelUri.java io/aeron/BufferBuilder.java io/aeron/protocol/SetupFlyweight.java io/aeron/protocol/NakFlyweight.java io/aeron/protocol/DataHeaderFlyweight.java io/aeron/protocol/HeaderFlyweight.java io/aeron/protocol/RttMeasurementFlyweight.java io/aeron/protocol/StatusMessageFlyweight.java io/aeron/status/ChannelEndpointStatus.java io/aeron/status/ReadableCounter.java io/aeron/status/HeartbeatStatus.java io/aeron/exceptions/ConductorServiceTimeoutException.java io/aeron/exceptions/RegistrationException.java io/aeron/exceptions/TimeoutException.java io/aeron/exceptions/ChannelEndpointException.java io/aeron/exceptions/DriverTimeoutException.java io/aeron/ExclusivePublication.java io/aeron/ClientConductor.java io/aeron/LogBuffers.java io/aeron/Counter.java io/aeron/DriverEventsAdapter.java io/aeron/ConcurrentPublication.java io/aeron/logbuffer/TermAppender.java io/aeron/logbuffer/FragmentHandler.java io/aeron/logbuffer/TermScanner.java io/aeron/logbuffer/ControlledFragmentHandler.java io/aeron/logbuffer/ExclusiveTermAppender.java io/aeron/logbuffer/TermGapFiller.java io/aeron/logbuffer/TermRebuilder.java io/aeron/logbuffer/TermGapScanner.java io/aeron/logbuffer/BufferClaim.java io/aeron/logbuffer/TermReader.java io/aeron/logbuffer/TermUnblocker.java io/aeron/logbuffer/RawBlockHandler.java io/aeron/logbuffer/BlockHandler.java io/aeron/logbuffer/FrameDescriptor.java io/aeron/logbuffer/ExclusiveBufferClaim.java io/aeron/logbuffer/LogBufferUnblocker.java io/aeron/logbuffer/TermBlockScanner.java io/aeron/logbuffer/Header.java io/aeron/logbuffer/HeaderWriter.java io/aeron/logbuffer/LogBufferDescriptor.java io/aeron/CncFileDescriptor.java io/aeron/CommonContext.java io/aeron/DriverProxy.java io/aeron/MappedLogBuffersFactory.java io/aeron/UnavailableCounterHandler.java io/aeron/command/ImageBuffersReadyFlyweight.java io/aeron/command/ControlProtocolEvents.java io/aeron/command/CounterUpdateFlyweight.java io/aeron/command/CounterMessageFlyweight.java io/aeron/command/ErrorResponseFlyweight.java io/aeron/command/CorrelatedMessageFlyweight.java io/aeron/command/DestinationMessageFlyweight.java io/aeron/command/PublicationBuffersReadyFlyweight.java io/aeron/command/RemoveMessageFlyweight.java io/aeron/command/SubscriptionMessageFlyweight.java io/aeron/command/PublicationMessageFlyweight.java io/aeron/command/ImageMessageFlyweight.java io/aeron/command/SubscriptionReadyFlyweight.java io/aeron/command/OperationSucceededFlyweight.java io/aeron/EndOfStreamHandler.java io/aeron/DirectBufferVector.java io/aeron/UnavailableImageHandler.java io/aeron/FragmentAssembler.java io/aeron/Subscription.java io/aeron/ImageControlledFragmentAssembler.java io/aeron/Aeron.java io/aeron/AvailableImageHandler.java io/aeron/ChannelUriStringBuilder.java io/aeron/ControlledFragmentAssembler.java io/aeron/DriverEventsListener.java debug-loss-10.properties low-latency.properties aeron-throughput.properties high-stream-count.properties aeron-ipc.properties io/aeron/driver/CongestionControlSupplier.java io/aeron/driver/cmd/RemoveCoolDownCmd.java io/aeron/driver/cmd/AddSubscriptionCmd.java io/aeron/driver/cmd/NewPublicationImageCmd.java io/aeron/driver/cmd/RemovePublicationCmd.java io/aeron/driver/cmd/DriverConductorCmd.java io/aeron/driver/cmd/AddSubscriptionAndSessionCmd.java io/aeron/driver/cmd/RegisterSendChannelEndpointCmd.java io/aeron/driver/cmd/RemoveSubscriptionAndSessionCmd.java io/aeron/driver/cmd/CreatePublicationImageCmd.java io/aeron/driver/cmd/RemoveSubscriptionCmd.java io/aeron/driver/cmd/ChannelEndpointErrorCmd.java io/aeron/driver/cmd/AddDestinationCmd.java io/aeron/driver/cmd/SenderCmd.java io/aeron/driver/cmd/CloseSendChannelEndpointCmd.java io/aeron/driver/cmd/RegisterReceiveChannelEndpointCmd.java io/aeron/driver/cmd/RemoveDestinationCmd.java io/aeron/driver/cmd/NewPublicationCmd.java io/aeron/driver/cmd/CloseReceiveChannelEndpointCmd.java io/aeron/driver/cmd/ReceiverCmd.java io/aeron/driver/StatusMessageHandler.java io/aeron/driver/SubscriberPosition.java io/aeron/driver/StaticWindowCongestionControl.java io/aeron/driver/IpcPublication.java io/aeron/driver/MinMulticastFlowControl.java io/aeron/driver/DefaultSendChannelEndpointSupplier.java io/aeron/driver/FeedbackDelayGenerator.java io/aeron/driver/DriverConductor.java io/aeron/driver/OptimalMulticastDelayGenerator.java io/aeron/driver/Receiver.java io/aeron/driver/AeronClient.java io/aeron/driver/ThreadingMode.java io/aeron/driver/RetransmitHandler.java io/aeron/driver/LossDetector.java io/aeron/driver/SenderProxy.java io/aeron/driver/ext/CubicCongestionControl.java io/aeron/driver/ext/DebugSendChannelEndpoint.java io/aeron/driver/ext/CubicCongestionControlConfiguration.java io/aeron/driver/ext/RandomLossGenerator.java io/aeron/driver/ext/LossGenerator.java io/aeron/driver/ext/DebugReceiveChannelEndpointSupplier.java io/aeron/driver/ext/DebugSendChannelEndpointSupplier.java io/aeron/driver/ext/DebugChannelEndpointConfiguration.java io/aeron/driver/ext/DebugReceiveChannelEndpoint.java io/aeron/driver/ext/CubicCongestionControlSupplier.java io/aeron/driver/DriverManagedResource.java io/aeron/driver/DefaultReceiveChannelEndpointSupplier.java io/aeron/driver/Configuration.java io/aeron/driver/Subscribable.java io/aeron/driver/DefaultCongestionControlSupplier.java io/aeron/driver/PreferredMulticastFlowControl.java io/aeron/driver/LossHandler.java io/aeron/driver/RetransmitSender.java io/aeron/driver/NetworkPublicationThreadLocals.java io/aeron/driver/DataPacketHandler.java io/aeron/driver/DefaultMulticastFlowControlSupplier.java io/aeron/driver/FlowControl.java io/aeron/driver/FlowControlSupplier.java io/aeron/driver/EventLog.java io/aeron/driver/status/PerImageIndicator.java io/aeron/driver/status/PublisherLimit.java io/aeron/driver/status/SystemCounters.java io/aeron/driver/status/PublisherPos.java io/aeron/driver/status/SendChannelStatus.java io/aeron/driver/status/StatusUtil.java io/aeron/driver/status/SystemCounterDescriptor.java io/aeron/driver/status/SenderLimit.java io/aeron/driver/status/StreamPositionCounter.java io/aeron/driver/status/SenderPos.java io/aeron/driver/status/ReceiveChannelStatus.java io/aeron/driver/status/ReceiverHwm.java io/aeron/driver/status/SubscriberPos.java io/aeron/driver/status/ReceiverPos.java io/aeron/driver/status/ClientHeartbeatStatus.java io/aeron/driver/exceptions/InvalidChannelException.java io/aeron/driver/exceptions/ConfigurationException.java io/aeron/driver/exceptions/ControlProtocolException.java io/aeron/driver/exceptions/UnknownSubscriptionException.java io/aeron/driver/exceptions/ActiveDriverException.java io/aeron/driver/SetupMessageHandler.java io/aeron/driver/PublicationParams.java io/aeron/driver/DataPacketDispatcher.java io/aeron/driver/MaxMulticastFlowControlSupplier.java io/aeron/driver/DefaultUnicastFlowControlSupplier.java io/aeron/driver/CongestionControlUtil.java io/aeron/driver/Sender.java io/aeron/driver/CongestionControl.java io/aeron/driver/MediaDriver.java io/aeron/driver/SubscriptionParams.java io/aeron/driver/StaticDelayGenerator.java io/aeron/driver/MinMulticastFlowControlSupplier.java io/aeron/driver/UnicastFlowControl.java io/aeron/driver/ReceiverProxy.java io/aeron/driver/PreferredMulticastFlowControlSupplier.java io/aeron/driver/CounterLink.java io/aeron/driver/DriverConductorProxy.java io/aeron/driver/SendChannelEndpointSupplier.java io/aeron/driver/PublicationLink.java io/aeron/driver/SubscriptionLink.java io/aeron/driver/NetworkPublication.java io/aeron/driver/ReceiveChannelEndpointSupplier.java io/aeron/driver/ClientProxy.java io/aeron/driver/MaxMulticastFlowControl.java io/aeron/driver/PublicationImage.java io/aeron/driver/ClientCommandAdapter.java io/aeron/driver/reports/LossReportReader.java io/aeron/driver/reports/LossReportUtil.java io/aeron/driver/reports/LossReport.java io/aeron/driver/buffer/FileMappingConvention.java io/aeron/driver/buffer/MappedRawLog.java io/aeron/driver/buffer/RawLog.java io/aeron/driver/buffer/RawLogFactory.java io/aeron/driver/media/InterfaceSearchAddress.java io/aeron/driver/media/ReceiveChannelEndpoint.java io/aeron/driver/media/NetworkUtil.java io/aeron/driver/media/SocketAddressUtil.java io/aeron/driver/media/MultiDestination.java io/aeron/driver/media/ControlTransportPoller.java io/aeron/driver/media/ReceiveDestinationUdpTransport.java io/aeron/driver/media/UdpChannelTransport.java io/aeron/driver/media/SendChannelEndpoint.java io/aeron/driver/media/NetworkInterfaceShim.java io/aeron/driver/media/UdpChannel.java io/aeron/driver/media/ReceiveChannelEndpointThreadLocals.java io/aeron/driver/media/DataTransportPoller.java io/aeron/driver/media/UdpTransportPoller.java io/aeron/driver/PendingSetupMessageFromSource.java io/aeron/agent/EventLogAgent.java io/aeron/agent/EventConfiguration.java io/aeron/agent/CmdInterceptor.java io/aeron/agent/EventCode.java io/aeron/agent/ChannelEndpointInterceptor.java io/aeron/agent/EventLogger.java io/aeron/agent/EventLogReaderAgent.java io/aeron/agent/CleanupInterceptor.java io/aeron/agent/EventEncoder.java io/aeron/agent/EventDissector.java aeron-archive-codecs.xml fpl/sbe.xsd aeron-archive-mark-codecs.xml io/aeron/archive/ListRecordingsSession.java io/aeron/archive/SessionWorker.java io/aeron/archive/ControlSessionDemuxer.java io/aeron/archive/ArchiveMarkFile.java io/aeron/archive/Catalog.java io/aeron/archive/ArchiveConductor.java io/aeron/archive/ControlSession.java io/aeron/archive/ArchiveThreadingMode.java io/aeron/archive/RecordingSummary.java io/aeron/archive/SimpleFragmentHandler.java io/aeron/archive/ControlRequestAdapter.java io/aeron/archive/RecordingSession.java io/aeron/archive/status/RecordingPos.java io/aeron/archive/CatalogTool.java io/aeron/archive/ReplaySession.java io/aeron/archive/ArchivingMediaDriver.java io/aeron/archive/ControlRequestListener.java io/aeron/archive/ListRecordingsForUriSession.java io/aeron/archive/RecordingWriter.java io/aeron/archive/DedicatedModeArchiveConductor.java io/aeron/archive/Session.java io/aeron/archive/SharedModeArchiveConductor.java io/aeron/archive/AbstractListRecordingsSession.java io/aeron/archive/client/RecordingDescriptorPoller.java io/aeron/archive/client/RecordingEventsListener.java io/aeron/archive/client/ArchiveException.java io/aeron/archive/client/RecordingDescriptorConsumer.java io/aeron/archive/client/AeronArchive.java io/aeron/archive/client/ControlResponsePoller.java io/aeron/archive/client/RecordingEventsPoller.java io/aeron/archive/client/ArchiveProxy.java io/aeron/archive/client/ControlResponseAdapter.java io/aeron/archive/client/ControlResponseListener.java io/aeron/archive/client/RecordingEventsAdapter.java io/aeron/archive/ControlResponseProxy.java io/aeron/archive/package-info.java io/aeron/archive/Archive.java io/aeron/archive/RecordingFragmentReader.java io/aeron/archive/RecordingEventsProxy.java io/aeron/archive/codecs/SourceLocation.java io/aeron/archive/codecs/ListRecordingRequestDecoder.java io/aeron/archive/codecs/VarAsciiEncodingDecoder.java io/aeron/archive/codecs/RecordingDescriptorEncoder.java io/aeron/archive/codecs/MessageHeaderDecoder.java io/aeron/archive/codecs/RecordingDescriptorHeaderDecoder.java io/aeron/archive/codecs/ReplayRequestDecoder.java io/aeron/archive/codecs/StopReplayRequestEncoder.java io/aeron/archive/codecs/ControlResponseDecoder.java io/aeron/archive/codecs/StopRecordingRequestEncoder.java io/aeron/archive/codecs/StartRecordingRequestDecoder.java io/aeron/archive/codecs/RecordingProgressEncoder.java io/aeron/archive/codecs/mark/MarkFileHeaderEncoder.java io/aeron/archive/codecs/mark/VarAsciiEncodingDecoder.java io/aeron/archive/codecs/mark/MessageHeaderDecoder.java io/aeron/archive/codecs/mark/MarkFileHeaderDecoder.java io/aeron/archive/codecs/mark/MessageHeaderEncoder.java io/aeron/archive/codecs/mark/VarAsciiEncodingEncoder.java io/aeron/archive/codecs/mark/MetaAttribute.java io/aeron/archive/codecs/ConnectRequestDecoder.java io/aeron/archive/codecs/RecordingStartedDecoder.java io/aeron/archive/codecs/RecordingStoppedDecoder.java io/aeron/archive/codecs/ExtendRecordingRequestDecoder.java io/aeron/archive/codecs/TruncateRecordingRequestEncoder.java io/aeron/archive/codecs/CloseSessionRequestDecoder.java io/aeron/archive/codecs/ListRecordingsRequestDecoder.java io/aeron/archive/codecs/RecordingPositionRequestDecoder.java io/aeron/archive/codecs/ListRecordingsForUriRequestDecoder.java io/aeron/archive/codecs/CatalogHeaderEncoder.java io/aeron/archive/codecs/ControlResponseCode.java io/aeron/archive/codecs/StopReplayRequestDecoder.java io/aeron/archive/codecs/ReplayRequestEncoder.java io/aeron/archive/codecs/RecordingDescriptorHeaderEncoder.java io/aeron/archive/codecs/MessageHeaderEncoder.java io/aeron/archive/codecs/RecordingDescriptorDecoder.java io/aeron/archive/codecs/VarAsciiEncodingEncoder.java io/aeron/archive/codecs/ListRecordingRequestEncoder.java io/aeron/archive/codecs/MetaAttribute.java io/aeron/archive/codecs/StartRecordingRequestEncoder.java io/aeron/archive/codecs/StopRecordingRequestDecoder.java io/aeron/archive/codecs/ControlResponseEncoder.java io/aeron/archive/codecs/CatalogHeaderDecoder.java io/aeron/archive/codecs/ListRecordingsForUriRequestEncoder.java io/aeron/archive/codecs/RecordingPositionRequestEncoder.java io/aeron/archive/codecs/ListRecordingsRequestEncoder.java io/aeron/archive/codecs/CloseSessionRequestEncoder.java io/aeron/archive/codecs/TruncateRecordingRequestDecoder.java io/aeron/archive/codecs/ExtendRecordingRequestEncoder.java io/aeron/archive/codecs/RecordingStoppedEncoder.java io/aeron/archive/codecs/RecordingStartedEncoder.java io/aeron/archive/codecs/ConnectRequestEncoder.java io/aeron/archive/codecs/RecordingProgressDecoder.java fpl/sbe.xsd aeron-cluster-codecs.xml aeron-cluster-mark-codecs.xml io/aeron/cluster/MemberStatusListener.java io/aeron/cluster/ConsensusModule.java io/aeron/cluster/AuthenticatorSupplier.java io/aeron/cluster/RecordingCatchUpSupplier.java io/aeron/cluster/RecordingCatchUp.java io/aeron/cluster/MemberStatusAdapter.java io/aeron/cluster/ConsensusModuleSnapshotTaker.java io/aeron/cluster/SnapshotLoader.java io/aeron/cluster/DefaultAuthenticatorSupplier.java io/aeron/cluster/MemberStatusPublisher.java io/aeron/cluster/TimerService.java io/aeron/cluster/ClusterControl.java io/aeron/cluster/SessionProxy.java io/aeron/cluster/ClusteredMediaDriver.java io/aeron/cluster/ClusterSession.java io/aeron/cluster/EgressPublisher.java io/aeron/cluster/ClusterMember.java io/aeron/cluster/Authenticator.java io/aeron/cluster/LogAdapter.java io/aeron/cluster/LogPublisher.java io/aeron/cluster/SequencerAgent.java io/aeron/cluster/service/RecordingLog.java io/aeron/cluster/service/RecoveryState.java io/aeron/cluster/service/ServiceControlAdapter.java io/aeron/cluster/service/ClusteredServiceAgent.java io/aeron/cluster/service/NewActiveLogEvent.java io/aeron/cluster/service/ClusteredServiceContainer.java io/aeron/cluster/service/ServiceSnapshotLoader.java io/aeron/cluster/service/SnapshotTaker.java io/aeron/cluster/service/ServiceSnapshotTaker.java io/aeron/cluster/service/Cluster.java io/aeron/cluster/service/ClientSession.java io/aeron/cluster/service/ClusterNodeRole.java io/aeron/cluster/service/ClusteredService.java io/aeron/cluster/service/ClusterMarkFile.java io/aeron/cluster/service/ServiceControlPublisher.java io/aeron/cluster/service/ServiceControlListener.java io/aeron/cluster/service/RecordingExtent.java io/aeron/cluster/service/ServiceHeartbeat.java io/aeron/cluster/service/BoundedLogAdapter.java io/aeron/cluster/service/CommitPos.java io/aeron/cluster/Election.java io/aeron/cluster/IngressAdapter.java io/aeron/cluster/client/CredentialsSupplier.java io/aeron/cluster/client/EgressPoller.java io/aeron/cluster/client/NullCredentialsSupplier.java io/aeron/cluster/client/AeronCluster.java io/aeron/cluster/client/EgressListener.java io/aeron/cluster/client/EgressAdapter.java io/aeron/cluster/client/AuthenticationException.java io/aeron/cluster/client/SessionDecorator.java io/aeron/cluster/ClusterTool.java io/aeron/cluster/package-info.java io/aeron/cluster/codecs/GroupSizeEncodingDecoder.java io/aeron/cluster/codecs/ClientSessionDecoder.java io/aeron/cluster/codecs/ChallengeEncoder.java #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无