socket通信

布满荆棘的人生 2022-06-14 09:37 305阅读 0赞

## 一.服务端 ##

服务端开启socket，端口  
开输入流监听客户端信息  
读取客户端传来的信息并处理  
开启输出流并写出数据

## 二.客户端 ##

开启socket端口  
写出待处理数据  
开启输入流读取获取服务端传来的信息

附注：

## server: ##

public class Service {
        public static void main(String[] args) throws IOException {
            ServerSocket ss=new ServerSocket(6666);
            boolean flag=true;
            while(flag){
            //接收客户端的请求
            System.out.println("监听客户端的数据:");
            Socket sc = ss.accept();
            InputStream is = sc.getInputStream();
            byte[] buffer=new byte[1024];
            int len=-1;
            len=is.read(buffer);
            String getData=new String(buffer, 0, len);
            System.out.println("从客户端获取的数据:"+getData);
            //业务处理 大小写转化
            String outPutData=getData.toUpperCase();
            //向客户端写数据
            OutputStream os = sc.getOutputStream();
            os.write(outPutData.getBytes("UTF-8"));
            //释放资源
            os.close();
            is.close();
            sc.close();
            }
            ss.close();
        }
    }

## client: ##

public class Client {
        public static void main(String[] args) throws UnknownHostException, IOException {
            //获取用户输入的数据
                    Scanner input=new Scanner(System.in);
                    System.out.println("请输入数据:");
                    String inputData=input.nextLine();
    
                    //开启一个Socket端口
    // Socket sc=new Socket("127.0.0.1", 6666);
                    Socket sc=new Socket("192.168.0.124", 6666);
                    OutputStream os=sc.getOutputStream();
                    os.write(inputData.getBytes());
    
                    //获取服务端回传的数据
                    InputStream is = sc.getInputStream(); 
                    byte[] buffer=new byte[1024];
                    int len=-1;
                    len=is.read(buffer);
                    String getData=new String(buffer, 0, len);
                    System.out.println("从服务端获取的数据:"+getData);
                    //是否流
                    is.close();
                    os.close();
                    sc.close();
        }
    
    }