スキップしてメイン コンテンツに移動

投稿

10月, 2013の投稿を表示しています

P2P探訪 Raider 最初のメッセージ

TorrentクローンをJava で作成しています。
そろそろ、Applet上で動作するデモができそうです。 試してみて解ったことが結構ありました。
そこで、学習したしことを、epub形式でまとめています。http://p.booklog.jp/users/kyorohiro


やる気スイッチが入らないので、書きかけの物をさらします。



-----------------
最初のメッセージ TorrentクライアントはHandShakeが完了すると、次に 自分の持っているデータの相手に通知します。またデータを配信する場合、相手にデータを配信する意図がある事を伝えます。 どのデータを持っているかをBitfieldとして渡す。 最初に送信するメッセージはBitfieldです。自分がどのようなデータを持っているかを相手に知らせます。
データを分割して管理している  Torrent方式ではデータを分割して管理しています。 分割する単位はTorrentファイルに記載されておりTorrentネットワーク内で分割単位を共有しています。実際に分割したデータをPieceと読んでいます。通常、Pieceは「16KB」「32KB」「64KB」「128KB」「256KB」といった単位で分割されます。
 分割したデータには、1番から昇順に番号が降られます。例えば、160KBのデータを16KBで分割する場合、「0-16KB」までのデータを1番、「16-32KB」までのデータを2番、...「152KB-160KB」までのデータを10番と行った感じで番号が降られます。 データをBitfieldで渡す データを持っている場合は1。持っていない場合は0が設定します。例えば、160KBのデータを16KBで分割する場合、例えば、1番目のデータを持っている場合、「0x80 0x00」のようなバイトデータになります。 1番目と10番目のデータを持っている場合は、「0x80, 0x40」とったバイトデータになります。 以下のようなフォーマットで送信されます。 0-4バイト1+Bitfieldのサイズ4-5バイト55- Bitfieldの生データ(byte単位)  具体的に、 メッセージとして「0x00, 0x00, 0x00, 0x03, 0x05, 0x80, 0x40」のようなバイトデータを送信します。「0x00, 0x00…

P2P探訪 Raider ハンドシェークしてみる

TorrentクローンをJava で作成しています。
そろそろ、Applet上で動作するデモができそうです。 試してみて解ったことが結構ありました。
そこで、学習したしことを、epub形式でまとめています。http://p.booklog.jp/users/kyorohiro


やる気スイッチが入らないので、書きかけの物をさらします。



-----------------

ハンドシェークしてみるTrackerから、ピアの情報を所得できるようになりました。 これで、データを配信してるTorrentクライアントと接続できるようになりました。 本章では、他のTorrentクライアントへデータの転送許可を取る機能を実現します。 TorrentクライアントはTCPサーバー/クライアント TorrentクライアントはP2Pアプリです。Torrentクライアントはサーバーとクライアントの両方の機能を持っています。「他のTorrentクライアントから接続を受け入れ、データを配信する」というサーバー的な機能。そして、「他のTorrentクライアントへ接続しデータを転送してもらう」というクライアント的な機能です。  しかし、P2Pといっても、特別な方法で通信はしているわけではありません。汎用的な方法が利用されています。Torrentクライアントでは通信にTCP/IPを使用しています。TCP/IPはHttp通信で使用されています。これは、ブラウザーから「youtube」や「Google」にアクセスする時に使用する通信方法と同じ仕組みです。
Handshakeする 実際に、Torrentサーバーへ接続してみましょう。Torrent方式では、最初の接続/通信でデータ転送の許可をとります。この時、転送して欲しいデータについての情報をサーバーへ渡します。サーバーはそのデータが持っていれば、基本的に接続を受け入れます。 Socketで接続まずは、Trackerから取得したアドレスへTCP/IPのソケットを生成して接続します。 SocketChannel socketChannel = SocketChannel.open();; socketChannel.connect(new InetSocketAddress(hostname, port)); この時に生成したコネクションは、データ転送が完了するまで使用し…