Java本地如何用tcp转发流量,使用JAVA实现TCP数据转发

你是否有过这样的使用场景&＃xff0c;比如有一个数据库或主机&＃xff0c;因为安全、网络的关系&＃xff0c;在你的电脑上无法直接访问。但是此时你有一个中间的机子&＃xff0c;中间机子可以访问上述的数据库或主机&＃xff0c;同时你的电脑可以访问该中间机子。

开动歪脑筋&＃xff0c;能否在中间的机子上装一个什么软件&＃xff0c;可以在你的电脑上直接访问你之前所不能访问的数据库或主机&＃xff1f;

答案是肯定的&＃xff0c;在中间机子上装一个TCP数据转发软件就可以了。这种现成的软件很多&＃xff0c;linux自带的iptable也可以实现该功能。不过因为原理简单、还是自己动手、丰衣足食吧&＃xff0c;上代码&＃xff1a;

package com.ai.police.portmap;

import java.net.ServerSocket;

import java.net.Socket;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

public class TranslatePort {

private transient static Log log &＃61; LogFactory.getLog(TranslatePort.class);

public static void main(String[] args) {

try {

if(args &＃61;&＃61; null || args.length<3){

log.error("输出参数不能为空&＃xff0c;分别是 本地监听端口、远程IP、远程端口");

return;

}

//获取本地监听端口、远程IP和远程端口

int localPort &＃61; Integer.parseInt(args[0].trim());

String remoteIp &＃61; args[1].trim();

int remotePort &＃61; Integer.parseInt(args[2].trim());

//启动本地监听端口

ServerSocket serverSocket &＃61; new ServerSocket(localPort);

log.error("localPort&＃61;"&＃43;localPort &＃43; ";remoteIp&＃61;" &＃43; remoteIp &＃43;

";remotePort&＃61;"&＃43;remotePort&＃43;";启动本地监听端口" &＃43; localPort &＃43; "成功&＃xff01;");

while(true){

Socket clientSocket &＃61; null;

Socket remoteServerSocket &＃61; null;

try {

//获取客户端连接

clientSocket &＃61; serverSocket.accept();

log.error("accept one client");

//建立远程连接

remoteServerSocket &＃61; new Socket(remoteIp ,remotePort);

log.error("create remoteip and port success");

//启动数据转换接口

(new TransPortData(clientSocket ,remoteServerSocket ,"1")).start();

(new TransPortData(remoteServerSocket ,clientSocket,"2")).start();

} catch (Exception ex) {

log.error("",ex);

}

//建立连接远程

}

} catch (Exception e) {

log.error("",e);

}

}

}

package com.ai.police.portmap;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.Socket;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

/**

* 用于转发数据

* &＃64;author Administrator

*

*/

public class TransPortData extends Thread {

private transient static Log log &＃61; LogFactory.getLog(TranslatePort.class);

Socket getDataSocket;

Socket putDataSocket;

String type;

public TransPortData(Socket getDataSocket , Socket putDataSocket ,String type){

this.getDataSocket &＃61; getDataSocket;

this.putDataSocket &＃61; putDataSocket;

this.type &＃61; type;

}

public void run(){

try {

while(true){

InputStream in &＃61; getDataSocket.getInputStream() ;

OutputStream out &＃61; putDataSocket.getOutputStream() ;

//读入数据

byte[] data &＃61; new byte[1024];

int readlen &＃61; in.read(data);

//如果没有数据&＃xff0c;则暂停

if(readlen<&＃61;0){

Thread.sleep(300);

continue;

}

out.write(data ,0,readlen);

out.flush();

}

} catch (Exception e) {

log.error("type:"&＃43;type,e);

}

finally{

//关闭socket

try {

if(putDataSocket !&＃61; null){

putDataSocket.close();

}

} catch (Exception exx) {

}

try {

if(getDataSocket !&＃61; null){

getDataSocket.close();

}

} catch (Exception exx) {

}

}

}

}

测试结果&＃xff1a;

1、可以实现对oracle数据库、ssh 、telnet等转发&＃xff0c;客户端只要连到中间机子对应的端口上&＃xff0c;实现了直接操作后台数据库或主机的功能&＃xff1b;

2、上述代码不支持HTTP转发&＃xff0c;不能实现的原因并不是因为数据没有转发过去&＃xff0c;HTTP是基于TCP上的一种高层协议&＃xff0c;tcp数据肯定是转发给对应的web服务器了。不能实现的原因是http协议本身的原因&＃xff0c;http请求报文中的host参数包含了目的web服务器的ip和端口&＃xff0c;直接转发因为host数据不正确导致真正的web服务器会丢弃该请求&＃xff1b;另外&＃xff0c;还有其它http协议本身的原因&＃xff0c;回头我会专门撰写一篇HTTP数据转发来描述解决方案