问题描述
client和socket中各有一个数组，数组在不断变化，利用ObjectOutputStream和ObjectInputStream怎样实现交换？importjava.net.*;importjava.io.*;publicclassclient{int[][]map={{1,2},{3,4}};int[][]map2;Threadr1,r2;publicstaticvoidmain(String[]args){newclient().connect();}publicvoidconnect(){r1=newThread(newr1());r2=newThread(newr2());r1.start();r2.start();}publicvoidp(){for(inti=0;i<2;i++){for(intj=0;j<2;j++){System.out.println(""+map2[i][j]);}}}classr1implementsRunnable{Sockets1;ObjectOutputStreamout;publicvoidrun(){try{s1=newSocket("10.10.125.19",9999);out=newObjectOutputStream(s1.getOutputStream());}catch(UnknownHostExceptione){e.printStackTrace();}catch(IOExceptione){try{s1.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}while(true){try{out.writeObject(map);}catch(IOExceptione){try{out.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}}}}classr2implementsRunnable{Sockets2;ObjectInputStreamin;publicvoidrun(){try{s2=newSocket("10.10.125.19",8888);in=newObjectInputStream(s2.getInputStream());}catch(UnknownHostExceptione){e.printStackTrace();}catch(IOExceptione){try{s2.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}while(true){try{map2=(int[][])in.readObject();p();}catch(IOExceptione){try{in.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}catch(ClassNotFoundExceptione){e.printStackTrace();}}}}}importjava.io.*;importjava.net.*;publicclassServer{int[][]map={{5,6},{7,8}};int[][]map2;Threadr1,r2;publicstaticvoidmain(String[]args){Serveruc=newServer();uc.connect();}publicvoidconnect(){r1=newThread(newr1());r2=newThread(newr2());r1.start();r2.start();}publicvoidp(){for(inti=0;i<2;i++){for(intj=0;j<2;j++){System.out.println(""+map2[i][j]);}}}classr1implementsRunnable{ServerSockets1;Sockets;ObjectOutputStreamout;publicvoidrun(){try{s1=newServerSocket(8888);s=s1.accept();out=newObjectOutputStream(s.getOutputStream());}catch(IOExceptione){try{s1.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}while(true){try{out.writeObject(map);}catch(IOExceptione){try{out.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}}}}classr2implementsRunnable{ServerSockets2;Sockets;ObjectInputStreamin;publicvoidrun(){try{s2=newServerSocket(9999);s=s2.accept();in=newObjectInputStream(s.getInputStream());}catch(IOExceptione){try{s2.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}while(true){try{map2=(int[][])in.readObject();p();}catch(IOExceptione){try{in.close();}catch(IOExceptione1){e1.printStackTrace();}e.printStackTrace();}catch(ClassNotFoundExceptione){e.printStackTrace();}}}}}
解决方案
解决方案二：
没看懂你的意思，什么相互交换？？
解决方案三：
就是client和server中各有两个二维数值，假设其中一个数组是在不断的变化，client要对server发送自己变化的数组同时接受server的数组，server也是如此。
解决方案四：
具体分析1）是长度变化，还是数值变化2）变化的频率上面两个问题决定问题1）如何传输内容最小化，内存使用最小，性能最快建议：采用LinkedList做变长的队列，每次仅传输需要改变的数据问题2）如何最大化传输，确定使用短连接，还是长连接
解决方案五：
最简单实现方法，使用“序列化”数据方式，进行对象的传输