ソケットにおけるメッセージの送受信について

質問

いつもお世話になっています。
ソケットに関して質問します。

下記の手順でソケットを使用したいと考えています。
クラスAとクラスBが存在する。
1)クラスA:ソケット通信でメッセージ送信
2)クラスB:ソケット通信によるメッセージを取得
3)クラスB:ソケット通信で返信する
4)クラスA:ソケットによるメッセージを再取得する

このとき、クラスAがクラスBによるメッセージ再信が、３０秒以内にこなければ、ソケットを閉じる

それにあたってソースを１クラスで実行できるよう書き変えたいのですが、どうも上手くいきません。

実行したいメソッド手順が
ソケットを開く openSocket
ソケットにメッセージ送信 sendMsg
・・・１と３はこのメソッドを使用
メッセージ取得 getMsg
・・・2と４はこのメソッドを使用
ソケットを閉じる closeSocket
の順です。

自分で一度考えてみたソースは以下です。
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;

public class Messaneger{
private Socket socket;
private BufferedReader in;

// ソケットを開く
public void openSocket() {
ServerSocket serverSocket;

try {
serverSocket = new ServerSocket(5555);
System.out.println("クライアントからの接続をポート5555で待ちます");
// クライアントからの接続を待ちます
Socket socket = serverSocket.accept();
System.out.println(socket.getInetAddress() + "から接続を受付ました");

// 出力ストリームを取得
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
// 入力ストリームを取得
in = new BufferedReader(
new InputStreamReader( socket.getInputStream()));

} catch (IOException e) {}
}

//ソケットを閉じる
public void closeSocket() {

try {
socket.close();
} catch (IOException e) {}
}

/**
* ソケット通信でメッセージを送信
* @param 送信するメッセージ
*/
public void setMsg(String sendMsg) {

try {
socket = new Socket("localhost", 5555);
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
// 入力ストリームを取得
in = new BufferedReader(
new InputStreamReader(
socket.getInputStream()));
//サーバーにメッセージ送信
out.println( sendMsg );

//送信メッセージdata
System.out.println(sendMsg);
} catch (IOException e) {}
}

/**
* ソケット通信でメッセージを取得
* @return msg サーバーに渡されたメッセージ
*/
public String getMsg() {
String getMsg = "";
BufferedReader in;

try {
in = new BufferedReader(
new InputStreamReader(
socket.getInputStream()));
System.out.println(in.readLine());
} catch (IOException e) {}
return getMsg;
}
}

参考URL:http://www.hellohiro.com/socket.htm

宜しくお願いします。

回答No.3

matsu5200

askaaskaさんのおっしゃっている通り、基本的な理解が足りないんじゃないですかね。

まず、1～4について主語を付けて整理したらどうでしょう？

-----------------------------------------------------
1)クラスA:ソケット通信でメッセージ送信
2)クラスB:ソケット通信によるメッセージを取得(⇒受信)
3)クラスB:ソケット通信で返信する
4)クラスA:ソケットによるメッセージを再取得する
-----------------------------------------------------

登場人物 :
・クライアントソケット・・・socket = new Socket("localhost", 5555);
・サーバソケット・・・Socket socket = serverSocket.accept();

動作 :
・書き込む(out)
・読み込む(in)

でどうでしょうか。

お礼

お礼遅くなりました。

かなり、実力不足でした。
いまだに少し理解しきれていませんが、一度試して
再度もう少し勉強しなおしてまた質問させてもらいます。

回答ありがとうございました。
また、よろしくお願いします。