0

オブジェクトをシリアル化/逆シリアル化することで通信するJavaのクライアント/サーバーアプリケーションがあります。通常、クライアントはRequestObjを送信し、サーバーはResponseObjで応答します。サーバーもハートビートRequestObjを送信し、クライアントはハートビートResponseObjで応答します。

//Sample RequestObj
public class RequestObj implements Serializable {
   private static final long serialVersionUID = xxxx;  //auto generated
   int type; //TYPE_HEARTBEAT
   long time;
   ...

   public void setTime() {
      this.time=System.currentTimeMillis();
   }
}

サーバーから各クライアントにハートビートリクエストを送信する場合、同じRequestObj（接続ごと）を再利用し、現在の時刻を設定してからクライアントに送信します。現在の時間でRequestObjを受け取ることを期待しています。ただし、クライアントで逆シリアル化されたRequestObjは、常に間違った時間を与えるようです。実際、クライアントを受信したRequestObjは、最初のハートビートRequestObjとまったく同じ（同じオブジェクトID /アドレス）です。しかし、更新しない時間は？

//Sample Server side code sending heartbeat
public class ServerSocketWrapper {
   Socket socket;
   ObjectOutputStream oos;
   ...
   RequestObj heartbeat = New RequestObj(TYPE_HEARTBEAT);

   public void sendHeartBeat() {
      heartbeat.setTime();
      logger.info("HeartBeat {} {}", heartbeat.time, formatFullTime(heartbeat.time));
      oos.writeObject(heartbeat);
      oos.flush();
   }
}

以下にサンプルクライアントコードを示します。

//Sample Client side code receiving heartbeat
public class ClientSocketWrapper {
   Socket socket;
   ObjectInputStream ois;
   long heartbeatTime;
   ...

   public void run() {
      while(true) {
         Object obj = ois.readObject();
         if (obj instanceof RequestObj) {
            RequestObj req = (RequestObj) obj;
            if (req.type == TYPE_HEARTBEAT) {
       heartbeatTime = req.time;
               logger.info("Received heartbeat {} {} {}", heartbeatTime, formatFullTime(heartbeatTime), req);
               sendResponse(new ResponseObj(req.id, TYPE_HEARTBEAT));
            }
         }
         ...
      }
   }
}

これがログです

logs on the server
16:33:56.186 [pool-2-thread-2] INFO  ServerSocketWrapper - HeartBeat 1352842436186 2012-11-13 16:33:56.186
16:34:56.185 [pool-2-thread-2] INFO  ServerSocketWrapper - HeartBeat 1352842496185 2012-11-13 16:34:56.185
16:35:56.185 [pool-2-thread-1] INFO  ServerSocketWrapper - HeartBeat 1352842556185 2012-11-13 16:35:56.185

logs on the client
16:34:08.510 [server:port] INFO  ClientSocketWrapper - Received heartbeat 1352842436186 2012-11-13 16:33:56.186 RequestObj@8497904
16:35:06.758 [server:port] INFO  ClientSocketWrapper - Received heartbeat 1352842436186 2012-11-13 16:33:56.186 RequestObj@8497904
16:36:10.303 [server:port] INFO  ClientSocketWrapper - Received heartbeat 1352842436186 2012-11-13 16:33:56.186 RequestObj@8497904

クライアント側で受信した時間が更新されないのはなぜですか？JVMはある種のオブジェクトキャッシングを行っていますか？サーバーはjdk1.7.0764bで実行されていますが、クライアントはjdk1.6.3164bで実行されています。

4

2 に答える 2

2

同じ. ObjectOutputStream_ ObjectOutputStreamこれが、シリアライゼーションが参照のエイリアシングを維持できる方法です。

複数のメッセージにわたって参照追跡を行いたくない場合は、新しいメッセージごとに新しいObjectOutputStreamと のペア (またはのと) を作成します。これらのいずれも行わず、代わりにメッセージ オブジェクトを変更して再利用しない場合、変更が表示されないという問題は発生しませんが、代わりにリソースがリークします。これまで逆シリアル化されました。ObjectInputStream#resetObjectOutputStream#readUnsharedObjectInputStreamObjectInputStream

于 2012-11-13T22:19:10.523 に答える
1

はい、オブジェクトが ObjectOutputStream を介して送信されると、それを再送信すると、変更された場合でもreset()、ストリームで呼び出されない限り、以前に送信されたオブジェクトへの参照のみが送信されます。

于 2012-11-13T22:18:44.300 に答える