springboot NTRIP 服务端以及客户端 demo

NTRIP（Networked Transport of RTCM via Internet Protocol，基于互联网协议的差分数据传输）是一种用于实现高精度GPS定位的技术，通常用于农业、测绘、建筑等领域。Spring Boot是一个简化创建Spring应用的框架，可以帮助我们快速开发NTRIP服务端以及客户端。下面是一个基于Spring Boot的NTRIP服务端和客户端的示例代码。

### NTRIP服务端

NTRIP服务端代码如下：

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

public class NtripServer {

    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(2101);
        while (true) {
            Socket socket = serverSocket.accept();
            new Thread(new NtripServerThread(socket)).start();
        }
    }

}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

public class NtripServerThread implements Runnable {

    private Socket socket;

    public NtripServerThread(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            InputStream inputStream = socket.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String line = null;
            while ((line = bufferedReader.readLine()) != null) {
                System.out.println(line);
                if (line.startsWith("GET")) {
                    OutputStream outputStream = socket.getOutputStream();
                    String response = "ICY 200 OK\r\n" +
                            "Content-Type: gnss/data\r\n" +
                            "Server: NTRIP Example Server/1.0\r\n" +
                            "\r\n" +
                            "StreamName,1004,1,1\r\n";
                    outputStream.write(response.getBytes());
                    outputStream.flush();
                    break;
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (socket != null) {
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}

以上代码包含两个类，`NtripServer`是服务端的入口类，负责监听客户端的连接，并启动新线程去处理客户端请求；`NtripServerThread`是处理客户端请求的线程类，负责读取客户端发送的数据，并返回NTRIP协议的响应数据。

### NTRIP客户端

NTRIP客户端代码如下：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

public class NtripClient {

    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("localhost", 2101);
        OutputStream outputStream = socket.getOutputStream();
        String request = "GET / HTTP/1.1\r\n" +
                "User-Agent: NTRIP Example Client/1.0\r\n" +
                "Authorization: Basic cm9vdDp0ZXN0\r\n" +
                "Ntrip-Version: NTRIP/2.0\r\n" +
                "Connection: close\r\n" +
                "\r\n";
        outputStream.write(request.getBytes());
        outputStream.flush();

        InputStream inputStream = socket.getInputStream();
        InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
        BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
        String line = null;
        while ((line = bufferedReader.readLine()) != null) {
            System.out.println(line);
        }

        socket.close();
    }

}

以上代码是一个简单的NTRIP客户端，负责向服务端发送NTRIP协议的请求，并读取服务端返回的数据。

**注意：**以上代码仅作为示例，实际使用时需要根据具体情况进行修改。