/*
客户端
 */
public class Client {
    public static void main(String[] args) {
        //创建客户端
        try {
            Socket socket=new Socket("127.0.0.1",6666);//连接自己ip为127.0.0.1
            String s ="你好服务器";
            OutputStream output=socket.getOutputStream();
            output.write(s.getBytes());
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }
}

使用包装流输入输出：

public class Client {
    public static void main(String[] args) {

        try {
            Socket socket = new Socket("127.0.0.1",6666);

            String s = "你好服务器";
            DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());
            dataOutputStream.writeUTF(s);

            DataInputStream dataInputStream  = new DataInputStream(socket.getInputStream());
            String s1 = dataInputStream.readUTF();
            System.out.println(s1);

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

服务器程序的工作过程包含以下四个基本的步骤：

1.调用 ServerSocket(int port) ：

      创建一个服务器端套接字，并绑定到指定端口上。用于监听客户端的请求。

2.调用 accept()：

     监听连接请求，如果客户端请求连接，则接受连接，返回通信套接字对象。

3.调用 该Socket类对象的 getOutputStream() 和 getInputStream ()：

     获取输出流和输入流，开始网络数据的发送和接收。

4.关闭ServerSocket和Socket对象：

     客户端访问结束，关闭通信套接字。

服务器建立 ServerSocket 对象

      ServerSocket 对象负责等待客户端请求建立套接字连接，类似邮局某个窗口中的业务员。也就是说，服务器必须事先建立一个等待客户请求建立套接字连接的ServerSocket对象。

/*
服务器
 */
public class Server {
    public static void main(String[] args) {
        try {
            //创建服务器对象
            ServerSocket serverSocket=new ServerSocket(6666);
            System.out.println("服务器启动成功");
            //监听客户端是否向服务器发送链接请求

                Socket socket= serverSocket.accept();
                System.out.println("有客户端连接到了服务器");
                //后续操作
                InputStream input=socket.getInputStream();
                byte[]bytes=new byte[100];
                int size=input.read(bytes);
                String s=new String(bytes,0,size);
                System.out.println(s);


        }catch (IOException e){
                e.printStackTrace();
            System.out.println("服务器启动失败，端口已被占用");
        }
    }
}

使用包装流输入输出：

public class Server {
    public static void main(String[] args) {
        try {
            System.out.println("服务器开始启动");
            ServerSocket serverSocket =   new ServerSocket(6666);
            System.out.println("服务器启动成功");
            Socket socket = serverSocket.accept();

            //包装流 直接读到一个字符串
            DataInputStream dataInputStream = new DataInputStream(socket.getInputStream());
            String s = dataInputStream.readUTF();
            System.out.println(s);

            //从服务器端向客户端发送一个消息
            String s1 = "你好客户端!";

            DataOutputStream dataOutputStream = new DataOutputStream(socket.getOutputStream());
            dataOutputStream.writeUTF(s1);


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

UDP编程

    类 DatagramSocket 和 DatagramPacket 实现了基于 UDP 协议网络程序。

    UDP数据报通过数据报套接字 DatagramSocket 发送和接收，系统不保证UDP数据报一定能够安全送到目的地，也不能确定什么时候可以抵达。

     DatagramPacket 对象封装了UDP数据报，在数据报中包含了发送端的IP地址和端口号以及接收端的IP地址和端口号。

     UDP协议中每个数据报都给出了完整的地址信息，因此无须建立发送方和接收方的连接

流程：

1. DatagramSocket与DatagramPacket

2. 建立发送端，接收端

3. 建立数据报

4. 调用Socket的发送、接收方法

5. 关闭Socket

注意：发送端与接收端是两个独立的运行程序

发送端

/*
发送端
 */
public class Send {
    public static void main(String[] args) throws IOException {
        //用来发送和接受数据
        DatagramSocket datagramSocket=new DatagramSocket();
/*
    public DatagramPacket(byte buf[], int offset, int length,
                          InetAddress address, int port) {  参数分别为字节数组，从哪里开始发送 ，发送多长 ，用一个类来分装IP地址，端口
        setData(buf, offset, length);
        setAddress(address);
        setPort(port);
    }
 */
        byte []bytes="你好".getBytes();
        //数据报
        DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length, InetAddress.getByName("127.0.0.1"),6666);
        //发送
        datagramSocket.send(datagramPacket);


        System.out.println("发送完成");
    }
}

接收端，要指定监听的端口

/*
接收端
 */
public class Receive {
    public static void main(String[] args) throws IOException {
        //用来发送和接受数据
        DatagramSocket datagramSocket=new DatagramSocket(6666);

        //创建一个接受的数据报
        byte[]bytes=new byte[100];
        DatagramPacket datagramPacket=new DatagramPacket(bytes,0,bytes.length);

        //接受
        datagramSocket.receive(datagramPacket);

        String s=new String(bytes,0,datagramPacket.getLength());//datagramPacket.getLength()接受到数据的实际长度

    }
}