例子1:客户端发送信息给服务端,服务端将数据显式在控制台上public class TCPtest1{ //客户端 @Test public void client(){ Socket socket = null; OutputStream os = null; try { //1.创建Socket对象,指明服务端的ip和端口号 InetAddress inet = InetAddress.getByName("127.0.0.1"); socket = new Socket(inet, 8899); //2.获取一个输出流,用于输出数据 os = socket.getOutputStream(); os.write("你好我是客户端MM".getBytes()); //3.写出数据的操作 os.close(); } 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.创建服务器端的SeverSocket,指明自己的端口号 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.println(str);// } 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()); } catch (IOException e) { e.printStackTrace(); } finally { //5.关闭资源 if (is != null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if (baos != null){ try { baos.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(); } } } }}