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

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

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

outStream?=?new?DataOutputStream(zipOut);

請各位指教！多謝

|

調(diào)用了finish(),后ZIPStream就算設(shè)置了結(jié)束位

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

==========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();

總結(jié)

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

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