java实现网络通信小demo（src.zip

import org.junit.Test; import java.io.*; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import java.net.UnknownHostException; /** * 服务器和客户端之间通信依靠socket的getIntputStream和getOutputStream来相互通信 */ public class Test03 { @Test public void Client(){ Socket socket = null; InetAddress inet = null; FileInputStream fr = null; OutputStream os = null; InputStream isFromServer = null; try { inet = InetAddress.getByName("127.1.1"); socket = new Socket(inet,55535);//ip 端口号 fr = new FileInputStream("线路板.jpg");//读取文件 os = socket.getOutputStream();//通过流与服务器之间传输数据 byte[] transBytes = new byte[1024]; int readCount; while((readCount = fr.read(transBytes))!=-1){ os.write(transBytes,0,readCount); } System.out.println("传输完毕"); socket.shutdownOutput(); isFromServer = socket.getInputStream(); ByteArrayOutputStream baos = new ByteArrayOutputStream();//这样防止文字倍“劈开” byte[] bytes = new byte[20]; int len; while((len = isFromServer.read(bytes)) != -1){ // String str = new String(bytes,0,len); // System.out.println(str); baos.write(bytes,0,len); } System.out.println(baos.toString()); System.out.println("反馈接受完毕"); os.flush(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); }finally { try { socket.close(); } catch (IOException e) { e.printStackTrace(); } try { fr.close(); } catch (IOException e) { e.printStackTrace(); } try { os.close(); } catch (IOException e) { e.printStackTrace(); } try { isFromServer.close(); } catch (IOException e) { e.printStackTrace(); } // try { // baos.close(); // } catch (IOException e) { // e.printStackTrace(); // } } } @Test public void Server(){ ServerSocket ss = null; Socket socket = null;//用来接收ss.accept()返回的socekt InputStream is = null;//用来接受传输文件的读取流 FileOutputStream fos = null;//用来在本地新建一个文件 //新建一个用来发送信息的流 OutputStream fosForClient = null; try { ss = new ServerSocket(55535);//创建服务器套接字 socket = ss.accept();//接受文件传输用的套接字 is = socket.getInputStream();//读入传输文件的流 fos = new FileOutputStream("myPictureHaHa.jpg"); fosForClient = socket.getOutputStream();//给客户端反馈 int readCount; byte[] transBytes = new byte[1024]; while ((readCount = is.read(transBytes))!=-1){ fos.write(transBytes,0,readCount); } System.out.println("保存成功"); fosForClient.write("收到，您的电路板构造很精妙".getBytes()); System.out.println("反馈输出完毕"); } catch (IOException e) { e.printStackTrace(); }finally { try { fos.close(); } catch (IOException e) { e.printStackTrace(); } try { is.close(); } catch (IOException e) { e.printStackTrace(); } try { socket.close(); } catch (IOException e) { e.printStackTrace(); } try { ss.close(); } catch (IOException e) { e.printStackTrace(); } try { fosForClient.close(); } catch (IOException e) { e.printStackTrace(); } } } }