Tunnel是什么？
Tunnel存在的意义，就是使用http协议来传输非http协议的内容，在使用fiddler4抓包的时候，常常会看见Tunnel这样的包，打开之后会发现里面没有标准http协议的模式，没有http头，包体也和http协议包体不相同。
Tunnel可以用来做服务器和客户端进行双向交流，这就解决了http1.1中无法实现服务器主动给客户端发送信息的问题。
Springboot中如何实现Tunnel?
Springboot中提供了HttpTunnelServer来提供Tunnel这样的功能，我们可以先来看一看它的源码
public HttpTunnelServer(TargetServerConnection serverConnection) {
Assert.notNull(serverConnection, "ServerConnection must not be null");
this.serverConnection = serverConnection;
}
从构造方法中我们可以看出，传入了一个TargetServerConnection实例，而TargetServerConnection是一个函数式接口。
@FunctionalInterface
public interface TargetServerConnection {
ByteChannel open(int timeout) throws IOException;
}
在源码中，有一个该接口的实现类SocketTargetServerConnection
public class SocketTargetServerConnection implements TargetServerConnection {
public SocketTargetServerConnection(PortProvider portProvider) {
Assert.notNull(portProvider, "PortProvider must not be null");
this.portProvider = portProvider;
}
@Override
public ByteChannel open(int socketTimeout) throws IOException {
SocketAddress address = new InetSocketAddress(this.portProvider.getPort());
logger.trace(LogMessage.format("Opening tunnel connection to target server on %s", address));
SocketChannel channel = SocketChannel.open(address);
channel.socket().setSoTimeout(socketTimeout);
return new TimeoutAwareChannel(channel);
}
... ...
}
// SocketTargetServerConnection的构造函数传入的是函数式接口PortProvider，
// 是一个获取port的函数式接口
@FunctionalInterface
public interface PortProvider {
/**
* Return the port number.
* @return the port number
*/
int getPort();
}
很明显，这个方法是提供的该服务于其他服务进行Tunnel交互的，SocketTargetServerConnection的open函数是打开一个端口与远程端口进行交互。在Springboot自己的测试代码中
@Bean
DispatcherFilter filter(AnnotationConfigServletWebServerApplicationContext context) {
TargetServerConnection connection = new SocketTargetServerConnection(
() -> context.getWebServer().getPort());
HttpTunnelServer server = new HttpTunnelServer(connection); // 在webServer的对等端口，定义了一个HttpTunnelServer
HandlerMapper mapper = new UrlHandlerMapper("/httptunnel", new HttpTunnelServerHandler(server)); // 创建一个处理器
Collection<HandlerMapper> mappers = Collections.singleton(mapper); // 创建单例
Dispatcher dispatcher = new Dispatcher(AccessManager.PERMIT_ALL, mappers); // 创建处理任务分发
return new DispatcherFilter(dispatcher); // 监听并分发处理任务
}
// HttpTunnelServerHandler.java
public class HttpTunnelServerHandler implements Handler {
private HttpTunnelServer server;
public HttpTunnelServerHandler(HttpTunnelServer server) {
Assert.notNull(server, "Server must not be null");
this.server = server;
}
@Override
public void handle(ServerHttpRequest request, ServerHttpResponse response) throws IOException {
this.server.handle(request, response);
}
}
// 其中Handler也是一个函数式接口
@FunctionalInterface
public interface Handler {
/**
* Handle the request.
* @param request the request
* @param response the response
* @throws IOException in case of I/O errors
*/
void handle(ServerHttpRequest request, ServerHttpResponse response) throws IOException;
}
也就是说，在需要与远程进行Tunnel隧道传输的时候，HttpTunnelServer通过将数据包封装进Servlet中的方法，首先与远端服务器建立connet连接，连接建立成功以后，将数据包再通过Http的方法传出去。
有了HttpTunnelServer，我们就可以和远端集成服务器双向交流
炒鸡辣鸡原创文章，转载请注明来源
