java:网络编程

 

 

 

 

 

 

 

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class EchoServerDemo {

    public static void main(String[] args){
        //创建一个服务器端的socket(1024-65535)
        try {
            ServerSocket server = new ServerSocket(6666);
            System.out.println("服务器已经启动，正在等待客户端连接");
            //等待客户端的链接，造成阻塞，如果有客户端连接成功，立即返回一个socket对象
            Socket socket = server.accept();
            System.out.println("客户端连接成功" + server.getInetAddress().getHostAddress());
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            //通过输入流读取网络数据,如果没有数据，那么会阻塞
            String info = br.readLine();
            System.out.println(info);
            //获取输出流，向客户端返回消息
            PrintStream ps = new PrintStream(new BufferedOutputStream(socket.getOutputStream()));

            ps.println("echo" + info);
            ps.flush();
            //关闭
            ps.close();
            br.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import java.io.*;
import java.net.Socket;

public class EchoClientDemo {
    public static void main(String[] args) {
        //创建一个socket对象，指定要链接的服务器
        try {
            Socket socket = new Socket("localhost",6666);
            //获取socket的输入输出流
            PrintStream ps = new PrintStream(new BufferedOutputStream(socket.getOutputStream()));
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            ps.println("hello,my name is Bin");
            ps.flush();
            //读取服务器端返回的数据
            String info = br.readLine();
            System.out.println(info);
            ps.close();
            br.close();


        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

---