# HG changeset patch
# User kono
# Date 1219711928 -32400
# Node ID 80ef604d09dc92d31091e8c6f4be56bab8be4415
# Parent  99e598a1dbf83a4c3c98314f9104d28c6f5c435d
*** empty log message ***

diff -r 99e598a1dbf8 -r 80ef604d09dc rep/ServerSample.java
--- a/rep/ServerSample.java	Thu Jan 17 07:29:54 2008 +0900
+++ b/rep/ServerSample.java	Tue Aug 26 09:52:08 2008 +0900
@@ -6,88 +6,88 @@
 
 public class ServerSample
 {
-public static void main(String[] argv)
-throws Exception
-{
-// ƒZƒŒƒNƒ^‚Ì—pˆÓ
-Selector selector = Selector.open();
+	public static void main(String[] argv)
+	throws Exception
+	{
+		// セレクタ�用�
+		Selector selector = Selector.open();
 
-// ƒT�[ƒoƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ð�ì�¬�B5100”Ôƒ|�[ƒg‚ðŽó•tƒ|�[ƒg‚ÉŽw’è
-// �i”ñƒuƒ�ƒbƒNƒ‚�[ƒh‚É�Ý’è�F�d—v�j
-ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
-serverSocketChannel.configureBlocking(false);
-serverSocketChannel.socket().bind(new InetSocketAddress(5100));
+		// サー�ソケット�ャン�ルを作�。5100番�ートを�付�ート�指定
+		// （�ブロックモード�設定：��）
+		ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
+		serverSocketChannel.configureBlocking(false);
+		serverSocketChannel.socket().bind(new InetSocketAddress(5100));
 
-// ƒZƒŒƒNƒ^‚ɃT�[ƒoƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ð“o˜^�BƒT�[ƒo‚Ö‚ÌŽó•t‚ðŠÄŽ‹
-serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
+		// セレクタ�サー�ソケット�ャン�ルを登録。サー����付を監視
+		serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
 
-// ƒZƒŒƒNƒ^‚ɃCƒxƒ“ƒg‚ª’Ê’m‚³‚ê‚邲‚Æ‚É�ˆ—�
-while (true) {
+		// セレクタ�イベント�通知�れる���処�
+		while (true) {
 
-// ƒZƒŒƒNƒ^‚ɃCƒxƒ“ƒg‚ª”­�¶‚·‚é‚܂Ńuƒ�ƒbƒN
-selector.select();
+			// セレクタ�イベント�発生�る��ブロック
+			selector.select();
 
-// Šl“¾‚µ‚½ƒCƒxƒ“ƒg‚²‚Æ‚É�ˆ—�‚ðŽÀ�s
-for (SelectionKey selectionKey : selector.selectedKeys()) {
+			// �得��イベント���処�を実行
+			for (SelectionKey selectionKey : selector.selectedKeys()) {
 
-// ƒT�[ƒo‚ÌŽó•t�ˆ—�: 
-// ƒCƒxƒ“ƒg‚ªŽó•t‰Â”\‚Å‚ ‚é�ê�‡�AŽó‚¯•t‚¯‚é‚ׂ«‘Î�Û‚ª‚ ‚ê‚Î
-// ƒZƒŒƒNƒ^‚Ɏ擾‚µ‚½ƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ð“o˜^
-if (selectionKey.isAcceptable()) {
+				// サー���付処�: 
+				// イベント��付�能��る場����付�る��対象��れ�
+				// セレクタ��得��ソケット�ャン�ルを登録
+				if (selectionKey.isAcceptable()) {
 
-// ƒT�[ƒoƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚©‚çƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ðŠl“¾
-// ƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ðŒo—R‚µ‚ăNƒ‰ƒCƒAƒ“ƒg‚Æ’Ê�M‚Å‚«‚é
-SocketChannel socketChannel = serverSocketChannel.accept();
+					// サー�ソケット�ャン�ル�らソケット�ャン�ルを�得
+					// ソケット�ャン�ルを経由��クライアント�通信��る
+					SocketChannel socketChannel = serverSocketChannel.accept();
 
-// �Ú‘±�悪‚È‚­‚Ä‚à‚±‚±‚É�ˆ—�‚ª”ò‚Ô‚±‚Æ‚ª‚ ‚é�B‘Î�Û‚ª
-// null‚Ì�ê�‡‚Í�ˆ—�‚𔲂¯‚é
-if (null == socketChannel) continue;
+					// 接続先����も���処��飛�����る。対象�
+					// null�場��処�を抜�る
+					if (null == socketChannel) continue;
 
-// ƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ð”ñƒuƒ�ƒbƒNƒ‚�[ƒh‚É�Ý’è�i�d—v�j‚µ�A
-// ƒZƒŒƒNƒ^‚É“Ç‚Ý�ž‚Ý‚ð‘Î�Û‚Æ‚µ‚Ä“o˜^
-socketChannel.configureBlocking(false);
-socketChannel.register(selector, SelectionKey.OP_READ);
-socketChannel = null;
-}
+					// ソケット�ャン�ルを�ブロックモード�設定（��）��
+					// セレクタ�読�込�を対象���登録
+					socketChannel.configureBlocking(false);
+					socketChannel.register(selector, SelectionKey.OP_READ);
+					socketChannel = null;
+				}
 
-// ƒNƒ‰ƒCƒAƒ“ƒg‚Æ‚Ì’Ê�M�ˆ—�
-// “Ç�ž‚݉”\‚Å‚ ‚é�ê�‡�A“à—e•¨‚ð“Ç‚Ý‚±‚ñ‚Å•W�€�o—Í‚É•\Ž¦�B
-// ƒ�ƒbƒZ�[ƒW‚ðƒNƒ‰ƒCƒAƒ“ƒg‚É‘—�M‚µ‚Ä�AƒRƒlƒNƒVƒ‡ƒ“‚ð�Ø’f�B
-// ƒZƒŒƒNƒ^‚©‚ç“o˜^‚ð‰ð�œ
-else if (selectionKey.isReadable()) {
+				// クライアント��通信処�
+				// 読込��能��る場��内容物を読��ん�標準出力�表示。
+				// メッセージをクライアント��信���コ�クションを切断。
+				// セレクタ�ら登録を解除
+				else if (selectionKey.isReadable()) {
 
-// “o˜^‚³‚ê‚Ä‚¢‚éƒ\ƒPƒbƒgƒ`ƒƒƒ“ƒlƒ‹‚ðŽæ“¾
-SocketChannel socketChannel = 
-(SocketChannel)selectionKey.channel();
+					// 登録�れ��るソケット�ャン�ルを�得
+					SocketChannel socketChannel = 
+						(SocketChannel)selectionKey.channel();
 
-Charset charset = Charset.forName("US-ASCII");
-ByteBuffer byteBuffer = ByteBuffer.allocate(8192);
+					Charset charset = Charset.forName("US-ASCII");
+					ByteBuffer byteBuffer = ByteBuffer.allocate(8192);
 
-// ƒNƒ‰ƒCƒAƒ“ƒg‚©‚çƒ�ƒbƒZ�[ƒW‚ÌŽó�M
-switch (socketChannel.read(byteBuffer)) {
-case -1:
-// ƒNƒ‰ƒCƒAƒ“ƒg‘¤‚ª�Ú‘±‚ð�Ø’f‚µ‚Ä‚¢‚½�ê�‡‚Í�AƒT�[ƒo‚à
-// �Ú‘±‚ð�Ø’f�BƒZƒŒƒNƒ^‚©‚ç“o˜^‚ð�í�œ
-socketChannel.close();
-break;
-case 0:
-// “Ç‚Ý�ž‚ނׂ«ƒ�ƒbƒZ�[ƒW‚Í“Í‚¢‚Ä‚¢‚È‚¢‚Ì‚Å�ˆ—�‚ð”ò‚΂·
-continue;
-default:
-// ƒNƒ‰ƒCƒAƒ“ƒg‚©‚çƒ�ƒbƒZ�[ƒW‚ðŽæ“¾‚µ�A•W�€�o—Í‚Ö
-byteBuffer.flip();
-System.out.print("EEE: " + charset.decode(byteBuffer));
+					// クライアント�らメッセージ��信
+					switch (socketChannel.read(byteBuffer)) {
+					case -1:
+						// クライアント��接続を切断����場���サー�も
+						// 接続を切断。セレクタ�ら登録を削除
+						socketChannel.close();
+						break;
+					case 0:
+						// 読�込む��メッセージ�届�������処�を飛��
+						continue;
+					default:
+						// クライアント�らメッセージを�得��標準出力�
+						byteBuffer.flip();
+					System.out.print("EEE: " + charset.decode(byteBuffer));
 
-// ƒNƒ‰ƒCƒAƒ“ƒg‚Öƒ�ƒbƒZ�[ƒW‚ð‘—�M
-socketChannel.write(charset.encode("Good bye!\r\n"));
+					// クライアント�メッセージを�信
+					socketChannel.write(charset.encode("Good bye!\r\n"));
 
-// ƒNƒ‰ƒCƒAƒ“ƒg‚Æ‚Ì�Ú‘±‚ð�Ø’f�BƒZƒŒƒNƒ^‚©‚ç“o˜^‚ð�í�œ
-//socketChannel.close();
-break;
-}
-}
-System.out.println(selectionKey.toString());
-}
-}
-}
+					// クライアント��接続を切断。セレクタ�ら登録を削除
+					//socketChannel.close();
+					break;
+					}
+				}
+				System.out.println(selectionKey.toString());
+			}
+		}
+	}
 }
\ No newline at end of file