以下の2つのサンプルコードはローカルでTCP Socketを用いたEchoサーバ/クライアントを走らせるもの。Javaのネットワークプログラミングで基本となるクラスとメソッドの使いどころを確認しておきたくて作成。まぁ今はnioがデファクトですけど。
サーバ
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
package tcpechoserver; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketAddress; public class Main { private static final int BUFSIZE = 32; // 受信バッファサイズ public static void main(String[] args) throws IOException { int servPort = 5000; // サーバソケットの作成 ServerSocket servSock = new ServerSocket(servPort); int recvMsgSize; // 受信メッセージサイズ byte[] receiveBuf = new byte[BUFSIZE]; // 受信バッファ // クライアントからの接続を待ち受けるループ while (true) { Socket clntSock = servSock.accept(); // クライアントの接続を取得 SocketAddress clientAddress = clntSock.getRemoteSocketAddress(); System.out.println("接続中：" + clientAddress); InputStream in = clntSock.getInputStream(); OutputStream out = clntSock.getOutputStream(); while ((recvMsgSize = in.read(receiveBuf)) != -1) { out.write(receiveBuf, 0, recvMsgSize); } clntSock.close(); } // 到達不能コード } } |
クライアント
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
package tcpechoclient; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.net.SocketException; public class Main { public static void main(String[] args) throws IOException { String server = "localhost"; int servPort = 5000; byte[] data = "Hello, Net world".getBytes(); byte[] msg = new byte[data.length]; Socket socket = new Socket(server, servPort); System.out.println("サーバとの接続を確立。"); InputStream in = socket.getInputStream(); OutputStream out = socket.getOutputStream(); out.write(data); // サーバに文字列を送付 System.out.println("送信：" + new String(data)); // サーバからの返信を受信 int totalBytesRcvd = 0; int bytesRcvd; while (totalBytesRcvd < data.length) { // 全文を受信するまでloop if ((bytesRcvd = in.read( // 引数は読込データ、Offset、読込データ長 msg, totalBytesRcvd, data.length - totalBytesRcvd)) == -1) { throw new SocketException("接続遮断"); } totalBytesRcvd += bytesRcvd; } // while end System.out.println("受信：" + new String(msg)); socket.close(); } } |
尚、java.io.InputStream#read(byte b[], int off, int len)の仕様は下記の通り。
(忘れてたので備忘録としてメソッドのコメントより抜粋)
* @param b the buffer into which the data is read.
* @param off the start offset in arrayb
* at which the data is written.
* @param len the maximum number of bytes to read.
* @return the total number of bytes read into the buffer, or
*-1if there is no more data because the end of
* the stream has been reached.
使い方はサーバ→クライアントの順で起動する。
実行結果
サーバ側
|
1 |
接続中：/127.0.0.1:53562 |
クライアント側
|
1 2 3 |
サーバとの接続を確立。 送信：Hello, Net world 受信：Hello, Net world |
コメント
いろいろ調べていたらここに来ました。
私の知りたいことがここにありそうです。
xportのI/O出力はサンプルプログラムをVbで改造して使えるようになりましたが、入力の方はできなくて、
しょうがないからJavaのサンプルソースをEclipseに入れて、入力を読み取る仕組みやコードはどこにあるか
解析中です。
要するに私はxportを使ってランでI/Oの入力と出力をやりたいだけです。
たとえば外出先から留守にしている家の中の電灯を点けたり、部屋の温度が40度以上になったら外出先の
マイパソコンに通知(火災の報知ではない)してくれるとか、とにかくたわいもないことですが、そういったことを
独学でできるようになるまでの過程が楽しいです。でも、知識のある人からアドバイスを受けたほうが楽です。
最近仕事が立て込んでまして･･･コメント承認・返信遅れました。。来週からは欧州出張の為、ご連絡が滞るかもしれません。
さて、上記のソースをご覧頂いたようで、参考の一つになれば幸いです。基本I/Oストリームの考えはプログラミング言語横断ですので、サーバ/クライアントを、下記のような組み合わせにすることも可能なので、面白いです。
例) Java/VB、Java/ActionScript、C/Python
xportのI/O入出力プログラミングが上手く行くと良いですね。