Socket的连接

古城微笑少年丶 2023-06-10 03:23 8阅读 0赞

package com.sinosoft.web.controller.test.socket;
    
    import org.junit.Test;
    
    import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class SocketTest {
    
        //客户端
        @Test
        public void client() throws Exception{
            //连接serverSocket
            Socket socket = new Socket("127.0.0.1",999);
            InputStream inputStream = socket.getInputStream();
            byte [] bs = new byte[100];
            inputStream.read(bs);
            System.out.println("接收到的消息:"+new String(bs));
        }
        @Test
        public void server() throws Exception{
            ServerSocket serverSocket = new ServerSocket(999);
            //监听客户端的请求 如果监听到继续执行
            Socket socket = serverSocket.accept();
            //服务端向客户端发动消息
            OutputStream outputStream = socket.getOutputStream();
            outputStream.write("hello".getBytes());
            serverSocket.close();
            outputStream.close();
            socket.close();
        }
    
    
    
        @Test
        public void fileServerSocketServer() throws Exception{
            ServerSocket serverSocket = new ServerSocket(888);
            Socket accept = serverSocket.accept();
            OutputStream outputStream = accept.getOutputStream();
            //准备要发送的文件
            File file = new File("E:\\sino.out");
            //将文件读入到内存中
            InputStream inputStream = new FileInputStream(file);
            //定义每次发送文件的大小
            byte [] bytes = new byte[100];
            int len = -1;
            while((len =inputStream.read(bytes))!=-1){
                outputStream.write(bytes);
            }
    
        }
    
        @Test
        public void fileSocketClient() throws  Exception{
            //文件传输的客户端请求
            Socket socket = new Socket("127.0.0.1",888);
            InputStream inputStream = socket.getInputStream();
            byte [] bytes = new byte[100];
            int len = -1;
            OutputStream outputStream = new FileOutputStream("e:\\aa.out");
            while(((len = inputStream.read(bytes))!=-1)){
                outputStream.write(bytes);
            }
    
    
        }
    
    
    
    
    
    
    
    }