次のコード構造があります。
サーバーと対話する Client Handler クラスのフィールドである Transaction 型のトランザクション ハンドラー。(クライアント ハンドラーとサーバーが併置されている)、クライアントはシリアル化されたオブジェクト メッセージを介してクライアント ハンドラーと対話します。
クライアントから新しいトランザクション要求が来ると (オブジェクト入力ストリームの readObject() メソッドを使用してスレッドに来る)、一連の trx_handler.setFoo(trx.getFoo)) を実行します。これは問題なく動作し、最初のリクエストを処理できます。しかし、後続のリクエストが着信すると (ループ構造のために最初のリクエストが終了した後にのみ実行が開始されます)、trx ハンドラーがデフォルト値に再初期化されていることがわかります。オブジェクトはまだそこにありますが、内部のすべての値はこの問題の原因は何ですか?
私の最初の推測はガベージ コレクションですが、私のクライアント ハンドラー クラスには、常にこの trx_handler へのポインターがあります。
以下のコードは、何が起こるかを示しています。ステートメントは最初にタイプ start になるため、trx_handler は正しく初期化されます。次に、handle_statement が呼び出されます。その後、後続のステートメントを受け取る必要がありますが、この時点で trx_handler はデフォルト設定に再初期化されているため、access_set フィールドは null であり、セッション ID も同様であり、hande_statement でオブジェクトに加えられた変更は表示されません。
ありがとう
public class Handler {
private Statement trx_handler;
/* Constructor initialises trx_handler to new Statement(); */
public ClientHandler(final Socket socket, long uid, Server server, ObjectInputStream ois) throws IOException, Exception {
LOGGER.info("Constructing Handler");
this.uid = uid;
this.server = server;
this.socket = socket;
this.database = server.getDB();
this.trx_sys = database.getTransactionManager();
create_listening(socket, ois);
out = socket.getOutputStream();
oos = new ObjectOutputStream(out);
this.trx_handler = new Statement(false);
}
private void create_incoming(final Socket socket, final ObjectInputStream stream) {
Thread incoming = new Thread() {
@Override
public void run() {
ObjectInputStream ois = stream;
InputStream in = null;
while (true) {
Object statement = null;
try {
statement = ois.readObject();
execute_stat(statement, socket, null);
LOGGER.info("Ready to execute next ");
} catch (SocketException e) {
LOGGER.severe("Connection Closed");
return;
} catch (IOException e) {
LOGGER.severe("Connection Closed");
return;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
String error_message = e.getMessage();
send_error(socket, error_message);
}
}
}
};
incoming.setDaemon(true);
incoming.start();
}
private synchronized void execute_stat(Statement trx) {
if (trx.getTransactionState() == Consts.trx_end) {
trx_sys.commitTransaction(trx_handler);
return;
} else if (trx.getTransactionState() == Consts.trx_start) {
try {
trx_handler.setAccessSet(trx.getAccessSet());
trx_handler.setSession_id(trx.getSession_id());
trx_sys.startTransaction(trx_handler);
handle_statement(socket, trx_handler);
/* TEST HERE THAT FIELDS IN TRX_HANDLER ARE CORRECTLY SET (INCLUDING SOME MODIFIED IN
handle_statement and they are correctly set */
return;
} catch (Exception ex) {
Logger.getLogger(ClientHandler.class.getName()).log(Level.SEVERE, null, ex);
}
}
try {
LOGGER.info("Execute Trx: stat");
/* Can't see modifications made in the start case */
Statement stats = trx.getStatement();
trx_handler.setStatement(stats);
handle_statement(stats, socket, trx_handler);
} catch (Exception e) {
e.printStackTrace();
}
return;
}