Java 网络编程

一 网络编程

逻辑端口: 用于标识进程的逻辑地址 不同进程的标识

有效端口: 0~65535 其中0~1024系统使用或保留端口

//InetAddress Java中IP对象
import java.net.*;
class IPDemo {
    public static void main(String[] args) throws UnknownHostException {
        //通过名称(ip字符串or主机名)来获取一个ip对象
        InetAddress ip = InetAddress.getByName("www.baidu.com"); //java.net.UnknownHostException
        System.out.println("addr:" + ip.getHostAddress());
        System.out.println("name:" + ip.getHostName());
    }
}

二 Socket

套接字 通信的端点

就是为网络服务提供的一种机制 通信的两端都有Socket 网络通信其实就是Socket间的通信 数据在两个Socket间通过IO传输 (只要是网络传输 必须有Socket)

1. UDP

将数据及源和目的封装成数据包中 不需要建立连接

每个数据报的大小在限制在64k内

因无连接 是不可靠协议

不需要建立连接 速度快

//建立UDP的socket服务 DatagramSocket(封装了udp传输协议的socket对象 具备发送和接受功能)
//将要发送的数据封装成数据包
//通过UDP的socket服务 将数据包发送取出 DategramPacket
//关闭Socket
//在进行udp传输时 需要明确一个是发送端 一个是接收端
//发送端与接收端是两个独立的运行程序

//udp的发送端
import java.net.*;
class UdpSend {
    public static void main(String[] args)throws Exception {
        // 1 建立udp的socket服务
        DatagramSocket ds = new DatagramSocket(8888); //指定发送端口 不指定系统会随机分配。
        // 2 明确要发送的具体数据
        String text = "UDP 啪啪啪";
        byte[] buf = text.getBytes();
        // 3 将数据封装成了数据包
        DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getByName("10.1.31.127"), 10000);
        // 4 用socket服务的send方法将数据包发送出去
        ds.send(dp);
        // 5 关闭资源
        ds.close();
    }
}

//udp的接收端
class UdpRece {
    public static void main(String[] args) throws Exception {
        // 1 创建udp的socket服务 必须要明确一个端口 作用在于 只有发送到这个端口的数据才是这个接收端可以处理的数据
        DatagramSocket ds = new DatagramSocket(10000);
        // 2 定义数据包 用于存储接收到数据 先定义字节数组 数据包会把数据存储到字节数组中
        byte[] buf = new byte[1024];
        DatagramPacket dp = new DatagramPacket(buf, buf.length);
        // 3 通过socket服务的接收方法将收到的数据存储到数据包中
        ds.receive(dp); //该方法是阻塞式方法
        // 4 通过数据包的方法获取数据包中的具体数据内容 比如ip, 端口, 数据等等
        String ip = dp.getAddress().getHostAddress();
        int port = dp.getPort();
        String text = new String(dp.getData(), 0, dp.getLength()); //将字节数组中的有效部分转成字符串
        System.out.println(ip + ":" + port + "--" + text);
        // 5 关闭资源
        ds.close();
    }
}

2. TCP

建立连接 形成传输数据的通道

在连接中进行大数据量传输

通过三次握手完成连接 是可靠协议

必须建立连接 效率会稍低

//建立客户端(Socket) 和服务器端(ServerSocket)
//建立连接后 通过Socket中的IO流进行数据的传输
//关闭socket
//客户端与服务器端是两个独立的应用程序

//TCP客户端
import java.net.*;
import java.io.*;
//需求 客户端给服务器端发送一个数据
//1 建立tcp的socket服务 需要明确具体的地址和端口(这样才可以去试着建立连接 如果连接失败 会出现异常) ---> 三次握手
//2 如果连接成功 就意味着通道建立了 socket流就已经产生了 只要获取到socket流中的读取流和写入流即可 只要通过getInputStream和getOutputStream就可以获取两个流对象
//3 关闭资源
class  TcpClient {
    public static void main(String[] args) throws Exception {
        Socket s = new Socket("10.1.31.69", 10002);
        OutputStream out = s.getOutputStream(); //获取了socket流中的输出流对象
        out.write("TCP 啪啪啪".getBytes());
        s.close();
    }
}

//TCP服务端
class  TcpServer {
    public static void main(String[] args) throws Exception {
        // 1 创建服务端socket服务 并监听一个端口
        ServerSocket ss = new ServerSocket(10002);
        // 2 服务端为了给客户端提供服务 获取客户端的内容 可以通过accept方法获取连接过来的客户端对象
        Socket s = ss.accept(); //获取客户端对象
        String ip = s.getInetAddress().getHostAddress();
        System.out.println(ip + ".....connected");
        // 3 可以通过获取到的socket对象中的socket流和具体的客户端进行通讯
        InputStream in = s.getInputStream(); //读取客户端的数据 使用客户端对象的socket读取流
        byte[] buf = new byte[1024];
        int len = in.read(buf);
        String text = new String(buf, 0, len);
        System.out.println(text);
        // 4 如果通讯结束 关闭资源 (要先关客户端 再关服务端)
        s.close();
        ss.close();
    }
}

TCP传输最容易出现的问题

客户端连接上服务端 两端都在等待 没有任何数据传输 因为read方法或者readLine方法是阻塞式

解决办法: 自定义结束标记 使用shutdownInput shutdownOutput方法