代码示例1:客户端发送信息给服务端,服务端将数据显示在控制台上
//客户端 @Test public void client() { Socket socket = null; OutputStream os = null; try { //1.创建Socket对象,指明服务器端的ip和端口号 InetAddress inet = InetAddress.getByName("192.168.14.100"); socket = new Socket(inet,8899); //2.获取一个输出流,用于输出数据 os = socket.getOutputStream(); //3.写出数据的操作 os.write("你好,我是客户端mm".getBytes()); } catch (IOException e) { e.printStackTrace(); } finally { //4.资源的关闭 if(os != null){ try { os.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket != null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } //服务端 @Test public void server() { ServerSocket ss = null; Socket socket = null; InputStream is = null; ByteArrayOutputStream baos = null; try { //1.创建服务器端的ServerSocket,指明自己的端口号 ss = new ServerSocket(8899); //2.调用accept()表示接收来自于客户端的socket socket = ss.accept(); //3.获取输入流 is = socket.getInputStream(); //不建议这样写,可能会乱码// byte[] buffer = new byte[1024];// int len;// while((len = is.read(buffer)) != -1){// String str = new String(buffer,0,len);// System.out.print(str);// } //4.读取输入流中的数据 baos = new ByteArrayOutputStream(); byte[] buffer = new byte[5]; int len; while((len = is.read(buffer)) != -1){ baos.write(buffer,0,len); } System.out.println(baos.toString()); System.out.println("收到了来自于:" + socket.getInetAddress().getHostAddress() + "的数据"); } catch (IOException e) { e.printStackTrace(); } finally { if(baos != null){ //5.关闭资源 try { baos.close(); } catch (IOException e) { e.printStackTrace(); } } if(is != null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket != null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } if(ss != null){ try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } }
代码示例2:客户端发送文件给服务端,服务端将文件保存在本地
@Test public void client() { Socket socket = null; FileInputStream fis = null; OutputStream os = null; try { InetAddress inetAddress = InetAddress.getByName("127.0.0.1"); socket = new Socket(inetAddress, 8899); fis = new FileInputStream("bg1.jpg"); os = socket.getOutputStream(); byte[] buff = new byte[10]; int len; while ((len = fis.read(buff)) != -1) { os.write(buff, 0, len); } } catch (IOException e) { e.printStackTrace(); } finally { try { if (os != null) os.close(); } catch (IOException e) { e.printStackTrace(); } try { if (fis != null) fis.close(); } catch (IOException e) { e.printStackTrace(); } try { if (socket != null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } } @Test public void server() { ServerSocket ss = null; Socket socket = null; InputStream is = null; FileOutputStream fos = null; try { ss = new ServerSocket(8899); socket = ss.accept(); is = socket.getInputStream(); fos = new FileOutputStream("bg4.jpg"); byte[] buff = new byte[10]; int len; while ((len = is.read(buff)) != -1) { fos.write(buff, 0, len); } } catch (IOException e) { e.printStackTrace(); } finally { try { if (fos != null) fos.close(); } catch (IOException e) { e.printStackTrace(); } try { if (is != null) is.close(); } catch (IOException e) { e.printStackTrace(); } try { if (socket != null) socket.close(); } catch (IOException e) { e.printStackTrace(); } try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } }
代码示例3:从客户端发送文件给服务端,服务端保存到本地并返回“发送成功”给客户端,并关闭相应的连接
@Test public void client() { Socket socket = null; FileInputStream fis = null; OutputStream os = null; ByteArrayOutputStream baos = null; try { InetAddress inetAddress = InetAddress.getByName("127.0.0.1"); socket = new Socket(inetAddress, 8899); fis = new FileInputStream("bg1.jpg"); os = socket.getOutputStream(); byte[] buff = new byte[10]; int len; while ((len = fis.read(buff)) != -1) { os.write(buff, 0, len); } System.out.println("图片发送完成!"); // 关闭数据的输出 socket.shutdownOutput(); InputStream is = socket.getInputStream(); baos = new ByteArrayOutputStream(); byte[] buffer = new byte[20]; int len1; while ((len1 = is.read(buffer)) != -1) { baos.write(buffer, 0, len1); } System.out.println(baos.toString()); } catch (IOException e) { e.printStackTrace(); } finally { try { if (fis != null) fis.close(); } catch (IOException e) { e.printStackTrace(); } try { if (os != null) os.close(); } catch (IOException e) { e.printStackTrace(); } try { if (socket != null) socket.close(); } catch (IOException e) { e.printStackTrace(); } try { if (baos != null) baos.close(); } catch (IOException e) { e.printStackTrace(); } } } @Test public void server() { ServerSocket ss = null; InputStream is = null; FileOutputStream fos = null; try { ss = new ServerSocket(8899); Socket socket = ss.accept(); is = socket.getInputStream(); fos = new FileOutputStream("bg7.jpg"); byte[] buff = new byte[10]; int len; while ((len = is.read(buff)) != -1) { fos.write(buff, 0, len); } System.out.println("图片传输完成!"); OutputStream os = socket.getOutputStream(); os.write("图片已经收到了,很好看".getBytes()); } catch (IOException e) { e.printStackTrace(); } finally { try { if (fos != null) fos.close(); } catch (IOException e) { e.printStackTrace(); } try { if (is != null) is.close(); } catch (IOException e) { e.printStackTrace(); } try { if (ss != null) ss.close(); } catch (IOException e) { e.printStackTrace(); } } }