ソケットを使ってメッセージを回す

質問

ソケットを使ってメッセージをリング状に回す通信を考えています。クライアントを一台指定し、サーバを複数立ち上げます。クライアントからメッセージを受け取ったサーバが別のサーバに送ることができません。その時BindExceptionError Address Already in use.とエラー表示されます。ソケット通信で、別のIPとポート番号を新しく生成して送ることができないのでしょうか。プログラム等を記述してもらえたら幸いです。どうかよろしくお願いします。

回答No.6

ngsvx

もうひとつ、先にお断りしておきますが、私の方針でズバリのコードは書きませんので
ご了承下さい。

そのかわり、わかる範囲でなら、しつこく付き合います。

>イ．マシンＡから、何かを受け取ったら、すぐに転送する。＞
>
>イをやりたいと考えております。

わかりました。

確認しておきますが、そうすると、２バイト以上のデータを流す場合、
データが入り組んでしまいますが、よろしいのでしょうか？

やはり、ある程度のまとまりで送った方がいいと思いますけど。
例えば、改行までの１行ごとにおくるとか。

そうしないと、ごちゃごちゃになりますよ。

それと、プログラムの構造がおかしいようです。

基本的な構造は、

　・次をループで回す
　　・前のサーバーからデータを読む
　　・次のサーバーへ転送

となります。

もう少し具体的には、

　InputStream is = prevSocket.getInputStream();
　OutputStream os = nextSocket.getOutputStream();
　for( ; ; ){
　　int c = is.read();
　　os.write(c);
　}

と、こんな感じです。

このままだと、先ほど説明したように、ごちゃごちゃになりますから、
１行分を読んでから、書き込みをする等の工夫がいるでしょう。

この流れからいくと、前のサーバーと次のサーバーの両方に対して、
接続をしておかなければなりません。

とすると、次のサーバーの情報は、プログラム起動直後に設定してしまうのが
いいと思います。

ただし、接続するのは受信をした後です。起動直後では、次のサーバーが起動していない
可能性があるからです。

main(){

　//次のサーバーの情報（IPアドレス、ポート番号）を入力
　（入力処理）

　//受信待ち待機
　Socket prevSocket = server.accept();

　//次のサーバーへ接続
　Socket nextSocket = .....

　InputStream is = prevSocket.getInputStream();
　OutputStream os = nextSocket.getOutputStream();
　for( ; ; ){
　　int c = is.read();
　　os.write(c);
　}

もう一度見直しをして下さい。

補足

>そのかわり、わかる範囲でなら、しつこく付き合います。>
ありがとうございます。感謝しております。

>１行分を読んでから、書き込みをする等の工夫がいるでしょう。>
について、while((s = dis.readLine()) != null) のように改行ごとに読み込むように書き換えました。

ひとついい忘れましたことがありました。最終的には、Aが「Hello」と言うメッセージを投げると、受け取った複数のサーバ同士でリング状にグルグル回し、速度を測るアプリケーションを作ることが目標です。よって

＞//次のサーバーの情報（IPアドレス、ポート番号）を入力
　（入力処理）＞

を、ホスト名、ポート番号を指定してnextSocket = new Socket("sougou2-2",5555);//次のサーバーへ接続
と書き換えました。
私からの質問２つあるのですが

（１）readLine()で読み込んだのをwriteUTF()、writeChars()で書き込もうとすると、コンパイルで推奨されないAPIと警告が表示されます。どう書き換えればいいのかが分りません。

（２）速度を測るアプリケーションを作るには、入出力をDataInputStreamとBufferedInputStreamなどをどちらを記述すれば、最小限の効率の良い実装ができるのでしょうか？

以下、見直して書き換えました。よろしくお願いします。

import java.io.*;
import java.net.*;
import java.lang.*;
//メインクラス
class revp2p3 {

public static void main (String args[]) {
try {
System.out.println("サーバの用意始めます");
while(true){
ServerSocket ss = new ServerSocket(5555);

Socket prevSocket = ss.accept();//受信待ち待機

Socket nextSocket = new Socket("sougou2-2",5555);//次のサーバーへ接続
InputStream is = prevSocket.getInputStream();
DataInputStream dis = new DataInputStream(is);
OutputStream os = nextSocket.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
String s;
while((s = dis.readLine()) != null) {
System.out.println("メッセージ" + s);
dos.writeUTF(s);
}
ss.close();
dis.close();
dos.close();
}
}
catch(IOException e){
System.out.println("IOException main "+e);
}
catch(Exception e){
System.out.println("Exception main "+e);
}
}
注: revp2p3.java は推奨されない API を使用またはオーバーライドしています。
注: 詳細については、-deprecation オプションを指定して再コンパイルしてください。