java实现的bt协议项目源码ttorrent，非常不错的

【实例简介】
bittorrent协议的java实现，想学习或者做bt项目的同学可以参考。包含bencode，DHT，bittorrent 的完整实现。最低要求jdk6
【实例截图】
【核心代码】
db3d60bd-e589-4a33-a7ac-a7d435daa499
└── ttorrent-master
├── assembly.xml
├── bencoding
│   ├── pom.xml
│   └── src
│   ├── main
│   │   └── java
│   │   └── com
│   │   └── turn
│   │   └── ttorrent
│   │   └── bcodec
│   │   ├── BDecoder.java
│   │   ├── BEncoder.java
│   │   ├── BEValue.java
│   │   └── InvalidBEncodingException.java
│   └── test
│   └── java
│   └── BDecoderTest.java
├── bin
│   ├── ttorent-torrent
│   ├── ttorrent
│   └── ttorrent-tracker
├── cli
│   ├── pom.xml
│   └── src
│   └── main
│   └── java
│   └── com
│   └── turn
│   └── ttorrent
│   └── cli
│   ├── ClientMain.java
│   ├── TorrentMain.java
│   └── TrackerMain.java
├── common
│   ├── pom.xml
│   └── src
│   ├── main
│   │   └── java
│   │   └── com
│   │   └── turn
│   │   └── ttorrent
│   │   ├── common
│   │   │   ├── AnnounceableInformation.java
│   │   │   ├── creation
│   │   │   │   ├── CommonHashingCalculator.java
│   │   │   │   ├── DataSourceHolder.java
│   │   │   │   ├── HashingResult.java
│   │   │   │   ├── MetadataBuilder.java
│   │   │   │   ├── MultiThreadHashesCalculator.java
│   │   │   │   ├── PiecesHashesCalculator.java
│   │   │   │   ├── SingleThreadHashesCalculator.java
│   │   │   │   ├── Source.java
│   │   │   │   └── StringUtils.java
│   │   │   ├── ImmutableTorrentHash.java
│   │   │   ├── LoggerUtils.java
│   │   │   ├── Optional.java
│   │   │   ├── Pair.java
│   │   │   ├── Peer.java
│   │   │   ├── PeerUID.java
│   │   │   ├── protocol
│   │   │   │   ├── AnnounceRequestMessage.java
│   │   │   │   ├── AnnounceResponseMessage.java
│   │   │   │   ├── http
│   │   │   │   │   ├── HTTPAnnounceRequestMessage.java
│   │   │   │   │   ├── HTTPAnnounceResponseMessage.java
│   │   │   │   │   ├── HTTPTrackerErrorMessage.java
│   │   │   │   │   └── HTTPTrackerMessage.java
│   │   │   │   ├── PeerMessage.java
│   │   │   │   ├── TrackerMessage.java
│   │   │   │   └── udp
│   │   │   │   ├── UDPAnnounceRequestMessage.java
│   │   │   │   ├── UDPAnnounceResponseMessage.java
│   │   │   │   ├── UDPConnectRequestMessage.java
│   │   │   │   ├── UDPConnectResponseMessage.java
│   │   │   │   ├── UDPTrackerErrorMessage.java
│   │   │   │   └── UDPTrackerMessage.java
│   │   │   ├── SystemTimeService.java
│   │   │   ├── TimeService.java
│   │   │   ├── TorrentCreator.java
│   │   │   ├── TorrentFile.java
│   │   │   ├── TorrentHash.java
│   │   │   ├── TorrentInfo.java
│   │   │   ├── TorrentLoggerFactory.java
│   │   │   ├── TorrentMetadataImpl.java
│   │   │   ├── TorrentMetadata.java
│   │   │   ├── TorrentMetadataKeys.java
│   │   │   ├── TorrentParser.java
│   │   │   ├── TorrentSerializer.java
│   │   │   ├── TorrentStatistic.java
│   │   │   └── TorrentUtils.java
│   │   └── Constants.java
│   └── test
│   └── java
│   └── com
│   └── turn
│   └── ttorrent
│   └── common
│   ├── creation
│   │   ├── HashesCalculatorsTest.java
│   │   └── MetadataBuilderTest.java
│   ├── protocol
│   │   ├── http
│   │   │   └── HTTPAnnounceResponseMessageTest.java
│   │   └── udp
│   │   └── UDPAnnounceResponseMessageTest.java
│   ├── TorrentParserTest.java
│   └── TorrentUtilsTest.java
├── COPYING
├── INSTALL
├── network
│   ├── pom.xml
│   └── src
│   ├── main
│   │   └── java
│   │   └── com
│   │   └── turn
│   │   └── ttorrent
│   │   └── network
│   │   ├── AcceptAttachmentImpl.java
│   │   ├── AcceptAttachment.java
│   │   ├── ChannelListenerFactory.java
│   │   ├── ConnectionClosedException.java
│   │   ├── ConnectionListener.java
│   │   ├── ConnectionManagerContext.java
│   │   ├── ConnectionManager.java
│   │   ├── ConnectionWorker.java
│   │   ├── ConnectTask.java
│   │   ├── FirstAvailableChannel.java
│   │   ├── keyProcessors
│   │   │   ├── AcceptableKeyProcessor.java
│   │   │   ├── CleanupKeyProcessor.java
│   │   │   ├── CleanupProcessor.java
│   │   │   ├── ConnectableKeyProcessor.java
│   │   │   ├── InvalidKeyProcessor.java
│   │   │   ├── KeyProcessor.java
│   │   │   ├── KeyProcessorUtil.java
│   │   │   ├── ReadableKeyProcessor.java
│   │   │   └── WritableKeyProcessor.java
│   │   ├── NewConnectionAllower.java
│   │   ├── ReadAttachment.java
│   │   ├── ReadWriteAttachment.java
│   │   ├── SelectorFactory.java
│   │   ├── ServerChannelRegister.java
│   │   ├── TimeoutAttachment.java
│   │   ├── TimeoutStorageImpl.java
│   │   ├── TimeoutStorage.java
│   │   ├── WriteAttachment.java
│   │   ├── WriteListener.java
│   │   └── WriteTask.java
│   └── test
│   └── java
│   └── com
│   └── turn
│   └── ttorrent
│   └── network
│   ├── ConnectionManagerTest.java
│   ├── ConnectionWorkerTest.java
│   ├── keyProcessors
│   │   ├── CleanupKeyProcessorTest.java
│   │   └── WritableKeyProcessorTest.java
│   ├── StateChannelListenerTest.java
│   └── WorkingReceiverTest.java
├── pom.xml
├── README.md
├── test-api
│   ├── pom.xml
│   └── src
│   └── main
│   └── java
│   └── com
│   └── turn
│   └── ttorrent
│   ├── MockTimeService.java
│   ├── TempFiles.java
│   ├── Utils.java
│   └── WaitFor.java
├── tests
│   ├── pom.xml
│   └── src
│   └── test
│   ├── java
│   │   └── com
│   │   └── turn
│   │   └── ttorrent
│   │   ├── client
│   │   │   ├── announce
│   │   │   │   └── TrackerClientTest.java
│   │   │   └── CommunicationManagerTest.java
│   │   ├── common
│   │   │   └── TorrentTest.java
│   │   ├── CommunicationManagerFactory.java
│   │   ├── DummyPeerActivityListener.java
│   │   └── tracker
│   │   ├── TrackerAnnounceTest.java
│   │   ├── TrackerTest.java
│   │   └── TrackerUtils.java
│   └── resources
│   ├── parentFiles
│   │   ├── file1.jar
│   │   ├── file2.jar
│   │   └── parentDir
│   │   ├── AccuRevCommon.jar
│   │   ├── commons-io-cio2.5_3.jar
│   │   ├── commons-io-cio2.5_3.jar.link
│   │   ├── inDir
│   │   │   └── application.wadl
│   │   └── storage.version
│   └── torrents
│   ├── file1.jar.torrent
│   ├── file2.jar.torrent
│   ├── parentDir.linux.torrent
│   └── parentDir.win.torrent
├── ttorrent-client
│   ├── pom.xml
│   └── src
│   ├── main
│   │   └── java
│   │   └── com
│   │   └── turn
│   │   └── ttorrent
│   │   └── client
│   │   ├── announce
│   │   │   ├── AnnounceException.java
│   │   │   ├── Announce.java
│   │   │   ├── AnnounceResponseListener.java
│   │   │   ├── HTTPTrackerClient.java
│   │   │   ├── TrackerClientFactoryImpl.java
│   │   │   ├── TrackerClientFactory.java
│   │   │   ├── TrackerClient.java
│   │   │   └── UDPTrackerClient.java
│   │   ├── AnnounceableInformationImpl.java
│   │   ├── ClientState.java
│   │   ├── CommunicationManager.java
│   │   ├── Context.java
│   │   ├── EventDispatcher.java
│   │   ├── FileMetadataProvider.java
│   │   ├── Handshake.java
│   │   ├── LoadedTorrentImpl.java
│   │   ├── LoadedTorrent.java
│   │   ├── network
│   │   │   ├── CountLimitConnectionAllower.java
│   │   │   ├── DataProcessor.java
│   │   │   ├── DataProcessorUtil.java
│   │   │   ├── HandshakeReceiver.java
│   │   │   ├── HandshakeSender.java
│   │   │   ├── OutgoingConnectionListener.java
│   │   │   ├── ShutdownAndRemovePeerProcessor.java
│   │   │   ├── ShutdownProcessor.java
│   │   │   ├── StateChannelListener.java
│   │   │   └── WorkingReceiver.java
│   │   ├── peer
│   │   │   ├── MessageListener.java
│   │   │   ├── PeerActivityListener.java
│   │   │   ├── Rate.java
│   │   │   ├── SharingPeerInfo.java
│   │   │   └── SharingPeer.java
│   │   ├── PeerInformation.java
│   │   ├── PeersStorage.java
│   │   ├── PieceInformation.java
│   │   ├── Piece.java
│   │   ├── SelectorFactoryImpl.java
│   │   ├── SharedTorrent.java
│   │   ├── SharingPeerFactory.java
│   │   ├── SimpleClient.java
│   │   ├── storage
│   │   │   ├── EmptyPieceStorageFactory.java
│   │   │   ├── FairPieceStorageFactory.java
│   │   │   ├── FileCollectionStorage.java
│   │   │   ├── FileStorage.java
│   │   │   ├── FullyPieceStorageFactory.java
│   │   │   ├── PieceStorageFactory.java
│   │   │   ├── PieceStorageImpl.java
│   │   │   ├── PieceStorage.java
│   │   │   └── TorrentByteStorage.java
│   │   ├── strategy
│   │   │   ├── EndGameStrategyImpl.java
│   │   │   ├── EndGameStrategy.java
│   │   │   ├── RequestsCollectionImpl.java
│   │   │   ├── RequestsCollection.java
│   │   │   ├── RequestStrategyImplAnyInteresting.java
│   │   │   ├── RequestStrategyImplSequential.java
│   │   │   └── RequestStrategy.java
│   │   ├── TorrentConnectionListener.java
│   │   ├── TorrentListener.java
│   │   ├── TorrentListenerWrapper.java
│   │   ├── TorrentLoaderImpl.java
│   │   ├── TorrentLoader.java
│   │   ├── TorrentManagerImpl.java
│   │   ├── TorrentManager.java
│   │   ├── TorrentMetadataProvider.java
│   │   └── TorrentsStorage.java
│   └── test
│   └── java
│   └── com
│   └── turn
│   └── ttorrent
│   └── client
│   ├── ByteArrayStorage.java
│   ├── EventDispatcherTest.java
│   ├── network
│   │   └── HandshakeReceiverTest.java
│   ├── PeersStorageTest.java
│   ├── storage
│   │   ├── FairPieceStorageFactoryTest.java
│   │   ├── FileCollectionStorageTest.java
│   │   └── PieceStorageImplTest.java
│   └── strategy
│   └── RequestStrategyImplAnyInterestingTest.java
└── ttorrent-tracker
├── pom.xml
└── src
├── main
│   └── java
│   └── com
│   └── turn
│   └── ttorrent
│   └── tracker
│   ├── AddressChecker.java
│   ├── MultiAnnounceRequestProcessor.java
│   ├── PeerCollectorThread.java
│   ├── TorrentsRepository.java
│   ├── TrackedPeer.java
│   ├── TrackedTorrent.java
│   ├── Tracker.java
│   ├── TrackerRequestProcessor.java
│   └── TrackerServiceContainer.java
└── test
└── java
└── com
└── turn
└── ttorrent
└── tracker
├── MultiAnnounceRequestProcessorTest.java
└── TorrentsRepositoryTest.java

117 directories, 218 files