InputStreamからオブジェクトへの変換 - Spring統合

Question

クライアント/サーバアプリケーションのシリアル化のおかげで、TCP経由でオブジェクトを送信しようとしています。 TCPクライアントはアンドロイドシステムで書かれており、オブジェクトを送信するためにObjectOutputStreamを使用します。 TCPサーバーはバネ統合で書かれており、デシリアライザを使用してこのオブジェクトを読み取ろうとします。このような何か：私はデシリアライザ方式で引数であるInputSreamからのObjectInputStreamをcreateingいシリアライザとデシリアライザのインターフェイスを実装するクラスで

<int-ip:tcp-connection-factory id="hosServer" 
    serializer="connectionSerializeDeserialize" 
    deserializer="connectionSerializeDeserialize" ..... > 

。私はもう一度サーバーに接続しようとする瞬間までうまく動作します。次に、オブジェクト・フォームObjectInputStreamをreadObject（）メソッドで読み取っているときにEOFExceptionを受け取ります。

public class CommandConverter implements Serializer<Command>, Deserializer<Command>{ 

    private ObjectInputStream ois = null; 
    private ObjectOutputStream oos = null; 
    private CommandBuilder commandBuilder = new CommandBuilder(); 

    public Command deserialize(InputStream inputStream) throws IOException { 
     if (ois == null) 
      ois = new ObjectInputStream(inputStream); 
     Command cmd = null; 
     try { 
      cmd = (Command) ois.readObject(); 
     } catch (ClassNotFoundException e) { 
      commandBuilder.setCommandBuilder(new ImproperCommandBuilder()); 
      commandBuilder.createCommand(); 
      cmd = commandBuilder.getCommand(); 
     } catch (InvalidClassException e) { 
      commandBuilder.setCommandBuilder(new ImproperCommandBuilder()); 
      commandBuilder.createCommand(); 
      cmd = commandBuilder.getCommand(); 
     } 
     return cmd; 
    } 

バネ統合でTCP経由でオブジェクトを送信するにはどうすればよいですか？

Answer 1

SerializerおよびDeserializerの実装はスレッドセーフでなければなりません。それに到達する最も簡単な方法は、実装をステートレスにすることです。

クラスにこれらのプロパティがあるので、それらは異なる呼び出しの間で共有されます。そして、そのような状態を有することは、行動を予測不能にする。

ObjectInputStreamおよびObjectOutputStreamは、共有状態用に設計されていません。

ObjectInputStream ois = new ObjectInputStream(inputStream); 

など：

だから、あなたはObjectInputStreamにdeserialize()が呼び出されたすべての時間を作成する必要があります。