Java

本类阅读TOP10

·使用MyEclipse开发Struts框架的Hello World!(录像1)
·hibernate配置笔记
·AOP编程入门--Java篇
·linux下Tomcat 5.0.20 与 Apache 2 安装/集成/配置
·在win2003下整合了整合Tomcat5.5+ apache_2.0.53+ mod_jk_2.0.47.dll
·构建Linux下IDE环境--Eclipse篇
·Jsp 连接 mySQL、Oracle 数据库备忘(Windows平台)
·ASP、JSP、PHP 三种技术比较
·Tomcat5.5.9的安装配置
·AWT GUI 设计笔记(二)

分类导航
VC语言Delphi
VB语言ASP
PerlJava
Script数据库
其他语言游戏开发
文件格式网站制作
软件工程.NET开发
一个完整的读Socket中字节的方法

作者:未知 来源:月光软件站 加入时间:2005-5-13 月光软件站

如果在socket中有下面这种情况发生,就不能使用,一般的方法读取socket中的字节

Socket socket=new Socket(ip,port);
  socket.setSendBufferSize(1);

  socket.getOutputStream().write("nihaoddddddddddddddd".getBytes());
  socket.getOutputStream().flush();
  
  socket.getOutputStream().write("dajiahao".getBytes());
  socket.getOutputStream().flush();
  socket.getOutputStream().write("222".getBytes());
  socket.getOutputStream().flush();

 socket.getOutputStream().close();

可以使用下面的方法读取

public static byte[] readSocket(Socket socket) throws Exception{
  ArrayList l=new ArrayList();
  
  InputStream  out=socket.getInputStream();
  int totallen=0;
  int count;
  /**
   * 如果socket对方已经将socket关闭,再次读socket里面的内容放回count为负数;

  *  读socket超时,反回已经读的字节
   */
  for(;;){
   byte[] tmp=new byte[3000];
   try{
    //System.err.println(out.available());
    
    count=out.read(tmp);
    System.err.println("count"+count);
   }catch(Throwable e){
    e.printStackTrace();
    System.err.println("ddddddddddddd");
    break;
   }
    System.err.println("count"+count);
    if(count<=0){
     break;
    }
    totallen+=count;
    byte[] tmp2=new byte[count] ;
   
    System.arraycopy(tmp,0,tmp2,0,count);
    l.add(tmp2);
  }
  byte[] bs=new byte[totallen];
  int pos=0;
  for(int i=0;i<l.size();i++){
   byte[] tmp=(byte[])l.get(i);
   
   System.arraycopy(tmp,0,bs,pos,tmp.length);
   pos+=tmp.length;
  }
  return bs;
 }




相关文章

相关软件