JAVA SOCKET方式网络传输.doc

JAVA SOCKET方式网络传输文件业务调用图服务端长时间SOCKET监听服务启动Servlet 自启动配置StartSocketServletcom.relan.lanpay.servlet.StartSocketServlet 0StartSocketServlet/servlet/StartSocketServletServlet 自启动类，初始化程序public void init() throws ServletException System.out.println(平台启动);new Thread(new SocketRunnableService().start();Servlet 启动过程中释放线程调用socket监听，线程调用类public class SocketRunnableService implements java.lang.Runnablepublic void run() SocketService socketService=new SocketService();socketService.contextListener();接收文件的服务端代码public class SocketService public int contextListener()ServerSocket server=null; /创建端口监听sockettry server=new ServerSocket(4700); /监听4700端口System.out.println(监听4700端口开始); catch (IOException e) Socket socket=null; /获取socket对象try /通过socket服务端获取socket对象socket=server.accept();/此处等待客户端发送数据，如果是主线程则程序停止一直等待，因此需要线程调用； catch (IOException e) ByteArrayOutputStream byteArrayOutputStream =new ByteArrayOutputStream();try InputStream in=socket.getInputStream(); /获取到流信息,需要抛出异常byte buff=new byte1;int result=0;result=in.read(buff);while(result!=-1)for(int i=0;ibuff.length;i+=1)byteArrayOutputStream.write(buffi);result=in.read(buff);/buff=byteArrayOutputStream.toByteArray();System.out.println(传输文件完毕！);in.close(); /关闭流socket.close();server.close(); /socket服务必须关闭，否则获取不到新的socket对象String report=byteArrayOutputStream.toString();String reports=report.split(); /解析报文获得文件名，及其他信息/System.out.println( reports1 );File file=new File(E:+reports1); /写入到服务端E盘下的文件FileOutputStream fileOutputStream=new FileOutputStream(file); fileOutputStream.write(byteArrayOutputStream.toByteArray();fileOutputStream.close(); catch (IOException e) / TODO Auto-generated catch blocke.printStackTrace();/contextListener();new Thread(new SocketRunnableService().start();return 0;客户端发送文件代码public static void main(String args) String fileName=123.zip; /文件名String report=+fileName+; /拼接报文File file=new File(d:+fileName); /读取D盘下的文件try FileInputStream in=new FileInputStream(file);byte b=new byte1; /缓存int count=0;ByteArrayOutputStream byteArrayOutputStream =new ByteArrayOutputStream();count=in.read(b); while(count!=-1)for(int i=0;i+dis.readUTF();dis.close();ps.close();s.close();System.out.print(发送完成); catch (UnknownHostException e) / TODO Auto-g