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

質問

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

回答No.11

ngsvx

２つ書き忘れましたので追記しておきます。

１．文字列の比較

　文字列の比較は==ではありません。

　a = "1234";
　if(a.equals("1234")){
　}

　とします。

２．自マシンのIPアドレスの取得方法

　　ＩＰアドレスの文字列を取得するには、
　　import java.net.InetAddress;

　　InetAddress adr = InetAddress.getLocalHost();
　　String ipadr = adr.getHostAddress();

　　とすればＯＫです。

お礼

解決しました．ありがとうございます。

補足

分りました。次回からは、自分がどれだけできるかを説明するように気をつけます。今回初めてこの質問コーナーを利用させて貰いましたがいろいろと勉強になりました。以降も引き続き頑張りたいと思います。
　しかし、いろいろ調べましたが難しいですね。ngsvxさんの言われた箇所書き直したつもりですが、ここでは、次のIPアドレスとport番号をそれぞれargs[0]、args[1]のパラメータをとるようにしました。あと、文字列の比較はint型のcompareToによる比較で記述しました．
質問１．
transportToNext(ipadr,port,datas);
のところで、static void transportToNext(String ipadr, int port, List datas) {............}メソッドをどうやって引数（ipadr,port,datas)と共に渡して呼び出すことができるのでしょうか？
質問２．
static InetAddress getAddressByString(String ipadr) {...............}
メソッドの部分は、どこから呼び出してくるのでしょうか？質問１では、transportToNext(ipadr,port,datas);によってメソッドが呼び出されていると思うのですが、、
質問の内容おかしいかもしれませんが、お願いします！！

class Ring2 {
　public static void main(String[] args) {
　　try {
//ポートを取得する
　　　int port = Integer.parseInt(args[1]);
//サーバーソケット立ち上げ
　　　ServerSocket server = new ServerSocket(port);
//自分のアドレス取得
　　　InetAddress myadr = InetAddress.getLocalHost();
　　　String myip = myadr.getHostAddress();
　　　System.out.println("自分のIPアドレスは" + myip + "です");
　　　//次のマシンへ接続
　　　InetAddress ipadr = getAddressByString(args[0]);

　　　for( ;; ) {
　　　　Socket socket = server.accept();
//入力ストリームを取得
　　　　InputStream is = socket.getInputStream();
　　　　InputStreamReader isr = new InputStreamReader(is);
　　　　BufferedReader br = new BufferedReader(isr);

//全行を読み込む
　　　　List datas = new ArrayList();
　　　　String line = br.readLine();
　　　　while( !line.equals("") ) {//読み込んだ行が空白でなければループ
　　　　datas.add(line);//連結リストに読み込んだ行を加える
　　　　line = br.readLine();
　　　　}
　　　　br.close();

//コマンドによる分岐処理
　　　　String cmd = (String)datas.get(0);
　　　　if(cmd.equals("transport")) {
　　　　String goalip = (String)datas.get(1);
　　　　long startTime = Long.parseLong( (String)datas.get(2) );
　　　　int maxLoop = Integer.parseInt( (String)datas.get(3) );
　　　　int curLoop = Integer.parseInt( (String)datas.get(4) );
//compareToメソッドによって文字列を比較
　　　　int flag;
flag = myip.compareTo(goalip);
　　　　　if(flag == 0) {//自分の持っているIPがgoalIPと等しい場合
　　　　　　if(maxLoop <= curLoop) {
//終了処理
　　　　　　System.out.println("終了時間は"+ datas + "回った回数は" + maxLoop); //追加
　　　　　　} else {
//新周回処理
　　　　　　datas.set(4, Integer.toString(curLoop + 1));
//次へ転送
　　　　　　transportToNext(ipadr,port,datas);
　　　　　　}
　　　　　} else {
//IPが一致しない場合単純に次へ転送
transportToNext(ipadr,port,datas);
　　　　　}
　　　　}
　　　　socket.close();
　　　}
　　}
　　catch (IOException e) {
　　System.out.println("IOException main" + e);
　　}
　　catch (Exception e) {
　　System.out.println("Exception main" + e);
　　}
　}

　static void transportToNext(String ipadr, int port, List datas) {
//次のマシンへ接続
//InetAddress adr = getAddressByString(args[0]);
　Socket nextsocket = new Socket(ipadr,port);

//出力ストリーム取得
　OutputStream os = nextsocket.getOutputStream();
　PrintWriter pw = new PrintWriter(os);

//ストリームへ書き込み
　　for(int i = 0 ; i < datas.size() ; i++) {
　　pw.println((String)datas.get(i));
　　}
　pw.flush();
　pw.close();
　nextsocket.close();
　}

　static InetAddress getAddressByString(String ipadr) {
　String[] parts = ipadr.split("\\.");
　byte[] bParts = new byte[4];
　for(int i = 0 ; i < 4 ; i++) {
　bParts[i] = (byte)Integer.parseInt(parts[i]);
　}
　InetAddress adr = InetAddress.getByAddress(bParts);
　return adr;
　}
}