通信中要發大批量數據，發送前想進行壓縮，發送完一段數據后要進行驗證，然后才能繼續發。我使用GZipInputStream和GZipOutputStream進行處理，但發送完一段數據后，調用zipoutput.finish()后，在發數據就出現異常“write?beyond?end?of?stream”，但不調用finish數據不能發出去，以下是我的聲明代碼：

DataInputStream?inStream?=?new?DataInputStream(new?GZIPInputStream(dataSocket.getInputStream(),10000));

GZipOutputStream?zipOut?=?new?GZIPOutputStream(dataSocket.getOutputStream(),10000);

outStream?=?new?DataOutputStream(zipOut);

請各位指教！多謝

|

調用了finish(),后ZIPStream就算設置了結束位

看看下面的傳文件的例子，我隨手寫的，可能編譯有問題，但大體是這樣用的：

==========Server:

int?ret=0;

byte[]?tmpdata=new?byte[4096];

byte[]?data;

FileInputStream?in=new?FileInputStream("Test.txt");

Socket?client=server.accept();

BufferedOutputStream?out=new?BufferedOutputStream(new?GZIPOutputStream(client.getOutputStream()));

do{

ret=in.read(tmpdata);

System.out.println(ret);

if(ret==-1)?break;

data=new?byte[ret];

System.arraycopy(tmpdata,?0,?data,?0,?ret);

out.write(data);

out.flush();

}while(true);

in.close();

out.close();

==========Client:

int?ret;

byte[]?tmpdata=new?byte[4096];

byte[]?data;

Socket?c=new?Socket("heifei",?5050);

InputStream?in=c.getInputStream();

FileOutputStream?f=new?FileOutputStream("Test2.gz");

do{

ret=in.read(tmpdata);

if(ret==-1)break;

data=new?byte[ret];

System.arraycopy(tmpdata,?0,?data,?0,?ret);

f.write(data);

f.flush();

}while(true);

f.close();

in.close();

c.close();

總結

以上是生活随笔為你收集整理的java socket 二次发送_发过2次帖子，都没有了,再发。JAVA中SOCKET通信中的数据压缩问题...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。