TCP面向连接的socket通信

服务器端的java代码

      package com.aaa.servet;
      import java.io.BufferedReader;
      import java.io.IOException;
      import java.io.InputStreamReader;
      import java.net.ServerSocket;//导入java.net包，用于网络通讯
      import java.net.Socket;
      /**
       * 这种是基于TCP的案例。
       * @author teayear
       *
       */
      public class ServerSocketTest {
     	public static void main(String[] args) {
      		System.out.println("...启动TCP Socket服务器...");
     		//1.初始化服务端Socket并绑定端口为8888
     		try {
      			ServerSocket serverSocket=new ServerSocket(8888);//需要添加try/catch块
     			//2.等待客户端的连接
      			Socket socket=serverSocket.accept();
     			//3.获取输入流,通过socket对象流，传递给缓冲字符流进行读取;
      			BufferedReader bufferReader=new BufferedReader(new InputStreamReader(socket.getInputStream(),"utf-8"));
     			//4.读取一行数据;
      // String str=bufferReader.readLine();
      			String str;
     			//4.1升级，通过循环升级接受信息;
     			while((str=bufferReader.readLine())!=null){
     				//5.输出打印
      				System.out.println(str);
      			}
      		} catch (IOException e) {
      			e.printStackTrace();
      		}
      	}
      }
  
 

效果如下：

      import java.io.BufferedReader;
      import java.io.BufferedWriter;
      import java.io.IOException;
      import java.io.InputStreamReader;
      import java.io.OutputStreamWriter;
      import java.net.Socket;
      import java.net.UnknownHostException;
      public class ClientSocket {
     	public static void main(String[] args) {
     		//1.创建socket对象，建立到服务i端的连接;
     		try {
      			Socket socket=new Socket("127.0.0.1",8888);
     			//2.通过缓冲输出流，包装下socket对象的输出字节流，进行写操作;
      			BufferedWriter bufferWriter=new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"GBK"));
     			//通过标准输入流获取字符流;
      			BufferedReader bufferReader=new BufferedReader(new InputStreamReader(System.in,"GBK"));
     			//循环升级；
     			while(true){
      				String str=bufferReader.readLine();
      				bufferWriter.write(str);
      				bufferWriter.write("\n");
     				//3.2还需要将缓冲中的内容放到socket
      				bufferWriter.flush();
      			}
     			//4.注意一定要有关闭连接;
      // socket.shutdownOutput();
      		} catch (UnknownHostException e) {
      			e.printStackTrace();
      		} catch (IOException e) {
      			e.printStackTrace();
      		}
      	}
      }
  
 

在服务器端会显示：

文章来源: aaaedu.blog.csdn.net，作者：tea_year，版权归原作者所有，如需转载，请联系作者。

原文链接：aaaedu.blog.csdn.net/article/details/88106657