Java网络编程初尝试

旧城等待， 2022-05-24 03:59 237阅读 0赞

服务器端代码：

package JavaDay5_19.NetworkProgramming.Demo1;
    
    import org.junit.jupiter.api.Test;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    /**
     * @author myvina@qq.com
     * @date 18-5-19  下午4:22
     */
    
    public class MyServer implements Runnable {
        ServerSocket server = null;
    
        public MyServer(int port) {
            try {
                server = new ServerSocket(port);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        @Override
        public void run() {
            System.out.println("服务器启动中...\n等待用户的连接...");
            try {
                while (true) {
                    Socket socket = server.accept();
                    System.out.println(socket.getInetAddress().getHostAddress() + "已连接...");
                    OutputStream outputStream = socket.getOutputStream();
                    outputStream.write("服务器正在向你发送消息...".getBytes());
                    InputStream inputStream = socket.getInputStream();
                    int len = 0;
                    byte[] buf = new byte[1024];
                    while((len = inputStream.read(buf)) != -1) {
                        System.out.println("服务器接收到客户端的消息： " + new String(buf, 0, len));
                        outputStream.write(("服务器正在向你发送消息..." + new String(buf, 0, len)).getBytes());
                    }
                }
            } catch (IOException e) {
                System.out.println("服务器关闭...");
                e.printStackTrace();
            }
        }
    
        public static void main(String[] args) {
            new Thread(new MyServer(9999)).start();
        }
    }

客户端代码：

package JavaDay5_19.NetworkProgramming.Demo1;
    
    import org.junit.jupiter.api.Test;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.Socket;
    import java.net.UnknownHostException;
    import java.util.Scanner;
    
    /**
     * @author myvina@qq.com
     * @date 18-5-19  下午4:33
     */
    
    public class MyClient implements Runnable {
        Socket socket = null;
    
        public MyClient(String host, int port) {
            try {
                socket = new Socket(host, port);
                System.out.println("成功连接服务器...");
            } catch (UnknownHostException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        @Override
        public void run() {
            new SendMessage().start();
            try {
                InputStream is = socket.getInputStream();
                byte[] buf = new byte[1024];
                int len = 0;
                while((len = is.read(buf)) != -1) {
                    System.out.println(new String(buf, 0, len));
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    
        private class SendMessage extends Thread {
            @Override
            public void run() {
                Scanner scanner = null;
                OutputStream os = null;
                try {
                    scanner = new Scanner(System.in);
                    os = socket.getOutputStream();
                    String in = "";
                    do {
                        in = scanner.next();
                        os.write(in.getBytes());
                        os.flush();
                    } while (!in.equals("quit"));
                } catch (IOException e) {
                    e.printStackTrace();
                }
                scanner.close();
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    
        public static void main(String[] args) {
                new Thread(new MyClient("127.0.0.1",9999)).start();
        }
    }

运行结果：

![70][]

![70 1][]

总结：通过Server类和Client类，对Java网络编程有了初步的了解，希望能再接再厉！

[70]: /images/20220524/9046cfebebef49a29a98ccc91b1c22c7.png
[70 1]: /images/20220524/03d0f034d83e4a4bbaf42fdc82341d94.png