今天寫局域網(wǎng)聊天程序時遇到一個問題，就是 A給B發(fā)送消息1，然后發(fā)送消息2，B只能接受到2個消息1。截圖是這樣的：

在發(fā)送了 一個消息 你好 和一個消息 我是xxx 之后，另一端只能收到兩次你好

解決辦法就是在?ObjectOutputStream的對象發(fā)送之前調(diào)用 reset（）方法，然后 flush；

代碼如下：

package com.net;import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.net.InetAddress; import java.net.Socket;import javax.swing.JTextArea;import com.protocol.netData; import com.protocol.netData.TYPE;public class chatSocketwithPro extends Thread{//自帶協(xié)議的傳輸Socket chatSocket; ObjectOutputStream oos ;ObjectInputStream ois ;JTextArea showText;StringBuilder sb ;private netData recvdata,senddata; public chatSocketwithPro(Socket s) {sb = new StringBuilder();senddata = new netData();this.chatSocket = s;try {oos = new ObjectOutputStream(chatSocket.getOutputStream());} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}@Overridepublic void run() {read();}public void read(){try {ois = new ObjectInputStream(chatSocket.getInputStream());while(true){recvdata = null;recvdata = (netData) ois.readObject();TYPE p = recvdata.getType();if ( p.equals(TYPE.TYPE_CHAT)){//如果是聊天數(shù)據(jù)String text = showText.getText();sb.setLength(0);sb.append(text);sb.append(recvdata.getNeckName()+": "+recvdata.getData()+"\n");showText.setText(sb.toString());}else if( p.equals(TYPE.TYPE_FILE_REQ)){//如果是文件請求}else if( p.equals(TYPE.TYPE_FILE_END)){//如果是文件尾}else if(p.equals(TYPE.TYPE_FILE_DATA)){//文件數(shù)據(jù)}else if(p.equals(TYPE.TYPE_OTHER)){//其他數(shù)據(jù)}else{//未知？}}} catch (IOException e) {e.printStackTrace();System.out.println(e.getMessage());showText.setText(e.getMessage()+"\n對方已關(guān)閉聊天");showText.setEnabled(false);} catch (ClassNotFoundException e) {e.printStackTrace();}finally{try {ois.close();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}public void write(String message) {senddata.setType(TYPE.TYPE_CHAT);senddata.setData(message);try {//oos.reset();//加了這句就可以了！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！！oos.writeObject(senddata);oos.flush();} catch (IOException e) {System.out.println(e.getMessage());e.printStackTrace();}}public void closeSocket(){try {this.chatSocket.close();} catch (IOException e) {e.printStackTrace();}}public String getSocketHost(){InetAddress ia =chatSocket.getInetAddress();return ia.getHostAddress();}public void SetShowArea(JTextArea showtextArea) {showText = showtextArea;}}

猜想是這樣的： ObjectInputStream 需要 OutPutStream的header，不然就會一直阻塞。第一個消息正常發(fā)送之后，第二次發(fā)送可能會需要另一header，然后第二次消息發(fā)送之后沒有header，無法解析，就使用了第一次的Object。。。。

不知道這樣對不對，希望大神們指點一二

總結(jié)

以上是生活随笔為你收集整理的Java Socket编程中使用ObjectOutputStream 和 ObjectInputStream 出现问题的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。