JAVA实现telnet代理，对输入命令拦截

目前只是个简单版本，有一些难点没有突破(vi编辑器的处理)

package telnet.server;import jinghai.base.Environment;
import telnet.TelnetProxyMain;
import telnet.handle.Handle;import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.LinkedList;
import java.util.concurrent.CountDownLatch;/*** @author Chun* @create 2021-04-02 10:46**/
public class TelnetProxyServer extends Thread {Socket client;Socket accept;InputStream inServer;OutputStream outClient;CountDownLatch countDownLatch;public volatile static STATUS status;//状态public static STATUS login; //登录三个过程private static int index = 0;private static final int temp13 = 13;public TelnetProxyServer(Socket client, Socket accept, InputStream inServer, OutputStream outClient, CountDownLatch countDownLatch) throws IOException {this.client = client;this.accept = accept;this.inServer = inServer;this.outClient = outClient;this.countDownLatch = countDownLatch;}@Overridepublic void run() {LinkedList<Integer> linkedListProxyClient = new LinkedList<>();status = STATUS.CONNECT;    //设置状态login = STATUS.CONNECT;  //登录过程验证使用while (!accept.isClosed() && !client.isClosed()) {try {if (TelnetProxyMain.readClient == -1 || TelnetProxyMain.readServer == -1) break;TelnetProxyMain.readServer = inServer.read();} catch (IOException e) {e.printStackTrace();}//三个状态，连接，登录，交互(登录成功)if (status.getStatus().equalsIgnoreCase("CONNECT")) {   //连接过程直接将获取的值传给TelnetServer即可connectStatus(outClient);} else {//处理LOGIN和INTERACTIVE,存在公用部分try {statusPublic(inServer, outClient, linkedListProxyClient);} catch (IOException e) {e.printStackTrace();}}}countDownLatch.countDown();}private void connectStatus(OutputStream outClient) {try {outClient.write(TelnetProxyMain.readServer);//前21字节是连接过程产生的，第21个字节ascii是3表示正文结束（3 => 0x03 => ETX => (end of text) =>  正文结束）if (TelnetProxyMain.readServer == 3) {//TODO status状态转为Loginstatus = status.nextState(); //状态后移}} catch (IOException e) {e.printStackTrace();}}//老版，根据interactiveStatus去改private void checkLogin(boolean b, InputStream inServer, OutputStream outClient, LinkedList<Integer> linkedListProxyClient, byte[] bytes) throws IOException {if (b) {outClient.write(TelnetProxyMain.readServer);outClient.write(inServer.read());login = login.nextState();System.out.println("LegalOrder: " + new String(bytes));} else {inServer.read();    //去掉换行10outClient.write(27);outClient.write(27);}linkedListProxyClient.clear();index = 0;}private void statusPublic(InputStream inServer, OutputStream outClient, LinkedList<Integer> linkedListProxyClient) throws IOException {if (TelnetProxyMain.readServer == 10) {// 13表示回车键，10表示换行符(windows下是/r/n，linux下/n) ,证明输入结束，对输入的命令进行校验，合法发送给服务器，不合法打回//区分LOGIN和INTERACTIVE,如果用户名密码不需要拦截，则不用区分
//                if (status.getStatus().equalsIgnoreCase("LOGIN")) {
//                    loginStatus(inServer, outClient, linkedListProxyClient);
//                } else if (status.getStatus().equalsIgnoreCase("INTERACTIVE")) {// TODO 这里处理命令交互过程interactiveStatus(inServer, outClient, linkedListProxyClient);
//                }} else if (TelnetProxyMain.readServer == 8) { // 删除backspaceif (index != 0 && linkedListProxyClient.size() != 0) {linkedListProxyClient.remove(--index);}outClient.write(TelnetProxyMain.readServer);} else if (TelnetProxyMain.readServer == 27) {specialButtons(inServer, outClient, linkedListProxyClient);//特殊按键的处理，上下左右，home，end等} else if (TelnetProxyMain.readServer == 127) { //delete按键暂时没处理} else if (TelnetProxyMain.readServer != 3 && TelnetProxyMain.readServer != 13) {linkedListProxyClient.add(index++, TelnetProxyMain.readServer);outClient.write(TelnetProxyMain.readServer);}}private void specialButtons(InputStream inServer, OutputStream outClient, LinkedList<Integer> linkedListProxyClient) throws IOException {ByteArrayOutputStream special = new ByteArrayOutputStream();    //处理特殊字符上下左右，home、end、esc等special.write(TelnetProxyMain.readServer);int read = inServer.read();if (read == 91) {special.write(91);int read1 = inServer.read();//读一位if (read1 == 68 || read1 == 67) {//左右special.write(read1);outClient.write(special.toByteArray());if (read1 == 68 && index > 0) {index--;}if (read1 == 67 && index < linkedListProxyClient.size()) {index++;}}//其他目前来说直接过滤了else if (read1 == 65 || read1 == 66) {special.write(read1);outClient.write(special.toByteArray());} else if (read1 == 49 || read1 == 52) {special.write(inServer.read());outClient.write(special.toByteArray());}} else if (read == 27) { //escoutClient.write(TelnetProxyMain.readServer);//清空outClient.write(read);linkedListProxyClient.clear();index = 0;}}//三个过程：用户名，密码，域名private void loginStatus(InputStream inServer, OutputStream outClient, LinkedList<Integer> linkedListProxyClient) throws IOException {//转换成byte数组byte[] bytes = listToBytes(linkedListProxyClient);// TODO 这之后对用户名密码做拦截if (login.getStatus().equalsIgnoreCase("CONNECT")) {  // 用户名boolean b = Handle.checkUserName(bytes);checkLogin(b, inServer, outClient, linkedListProxyClient, bytes);} else if (login.getStatus().equalsIgnoreCase("LOGIN")) {  //密码boolean b = Handle.checkPassWord(bytes);checkLogin(b, inServer, outClient, linkedListProxyClient, bytes);} else if (login.getStatus().equalsIgnoreCase("INTERACTIVE")) {  //域名boolean b = Handle.checkDomainName(bytes);checkLogin(b, inServer, outClient, linkedListProxyClient, bytes);//TODO status状态转为INTERACTIVEif (b) status = status.nextState();index = 0;}}private void interactiveStatus(InputStream inServer, OutputStream outClient, LinkedList<Integer> linkedListProxyClient) throws IOException {//转换成byte数组byte[] bytes = listToBytes(linkedListProxyClient);String command = new String(bytes).trim();// TODO 对键入的命令检查校验boolean b = Handle.checkCommand(command);if (b) {if (Environment.isWindows) outClient.write(temp13);outClient.write(TelnetProxyMain.readServer);System.out.println("LegalOrder: " + new String(bytes));} else {for (int i = 0; i < bytes.length; i++) {outClient.write(8);}System.out.println(bytes.length + "个8");}linkedListProxyClient.clear();index = 0;}private byte[] listToBytes(LinkedList<Integer> linkedListProxyClient) {Integer[] ints = linkedListProxyClient.toArray(new Integer[0]);int len = ints.length;byte[] bytes = new byte[len];for (int i = 0; i < len; i++) {bytes[i] = (byte) (int) ints[i];}return bytes;}}

package telnet.client;import telnet.TelnetProxyMain;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.concurrent.CountDownLatch;/*** @author Chun* @create 2021-04-02 10:46**/
public class TelnetProxyClient extends Thread {Socket client;Socket accept;InputStream inClient;OutputStream outServer;CountDownLatch countDownLatch;public TelnetProxyClient(Socket client, Socket accept, InputStream inClient, OutputStream outServer, CountDownLatch countDownLatch) {this.client = client;this.accept = accept;this.inClient = inClient;this.outServer = outServer;this.countDownLatch = countDownLatch;}@Overridepublic void run() {while (!accept.isClosed() && !client.isClosed()) {try {if (TelnetProxyMain.readServer == -1 || TelnetProxyMain.readClient == -1) break;TelnetProxyMain.readClient = inClient.read();
//                System.out.println("返回="+TelnetProxyMain.readClient);outServer.write(TelnetProxyMain.readClient);} catch (IOException e) {try {outServer.flush();e.printStackTrace();} catch (IOException ioException) {ioException.printStackTrace();}break;}}countDownLatch.countDown();}
}

package telnet;import telnet.client.TelnetProxyClient;
import telnet.server.TelnetProxyServer;import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.CountDownLatch;/*** @author Chun* @create 2021-04-08 8:59**/
public class TelnetProxyMain {private final ServerSocket serverSocket;private final Socket client;private final Socket accept;private final InputStream inServer;private final OutputStream outServer;private final InputStream inClient;private final OutputStream outClient;public volatile static int readServer = 0;public volatile static int readClient = 0;private final CountDownLatch countDownLatch = new CountDownLatch(2);public TelnetProxyMain(String ip, int serverPort) throws IOException {serverSocket = new ServerSocket(55);accept = serverSocket.accept();inServer = accept.getInputStream();outServer = accept.getOutputStream();client = new Socket(ip, serverPort);inClient = client.getInputStream();outClient = client.getOutputStream();}/**** 思路1：(采用)目前实现思路是server接收客户端的字节，接收到保留并发送给telnetServer，当输入回车时去校验命令是否合法*    **出现的问题：当我们键入↑↓时应该是返回上一次的命令，这里有个问题就是当我们输入回车后client发送的只有回车并没有将命令发送过来，*      这样就导致我们接收到了空，无法对此命令进行拦截** 思路2：在TelnetServer发送给client处也就是我们自己实现的client处进行拦截发送的字节，*      拦截到就拼接，拼接成字符串，在server处仍然监听回车，敲入回车后校验命令是否合法。*    **出现的问题：这样会拦截到我们输入↑↓后server发送给client的命令，但是当我们在vi/vim编辑器里使用↑↓同样会出现问题。** ** 注：client我们输入命令后客户端想要显示，是需要server将这个字母的字节发送给client的，*      也就是client发送给server一个a(97)，server就需要回复client一个a(97)*/public void run() {try {//启动两个线程，分别作为代理的client和servernew TelnetProxyServer(client, accept, inServer, outClient, countDownLatch).start();new TelnetProxyClient(client, accept, inClient, outServer, countDownLatch).start();countDownLatch.await(); //等待两个子线程结束在执行} catch (InterruptedException | IOException e) {e.printStackTrace();} finally {try {client.close();accept.close();serverSocket.close();} catch (IOException e) {e.printStackTrace();}}}public static void main(String[] args) {try {TelnetProxyMain telnetProxyMain = new TelnetProxyMain(args[0],50000);telnetProxyMain.run();} catch (IOException e) {e.printStackTrace();}}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/437399.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【转】C# DataTable使用方法详解

【转】C# DataTable使用方法详解

在项目中常常常使用到DataTable,假设DataTable使用得当&#xff0c;不仅能使程序简洁有用&#xff0c;并且可以提高性能&#xff0c;达到事半功倍的效果&#xff0c;现对DataTable的使用技巧进行一下总结。 1、添加引用 1 using System.Data; 2、创建表 1 2 3 4 //创建一个…
阅读更多...
python求组合数c_科学网—Python 组合函数 C(n,m) - 杨玠的博文

python求组合数c_科学网—Python 组合函数 C(n,m) - 杨玠的博文

Python 中组合函数 C(n,m) n!/(m!*(n-m)!) 有两个&#xff1a; 1.itertools.combinations 返回一个对象&#xff0c;其自带指针函数 因此有可以使用 for&#xff0c;例如 a [1,2,3,4] c itertools.combinations(a,2) for i in c: print i 其返回结果为 (1, 2) (1, 3) (1, 4)…
阅读更多...
Qt undefined reference to,Error 255，找不到库函数的解决办法

Qt undefined reference to,Error 255，找不到库函数的解决办法

本人Qt新手&#xff0c;使用Qt5在windows上写一个拨号程序时需要用到一个库librasapi32.a&#xff0c;RAS功能&#xff08;远程访问服务&#xff09;&#xff0c;用来拨号&#xff0c;说明一下这是和VC编程中的静态链接库一样的&#xff0c;只不过名字是Qt重新起的。然后虽然包…
阅读更多...
LeetCode每日打卡 - 汉明距离

LeetCode每日打卡 - 汉明距离

位异或运算&#xff08;^&#xff09; 运算规则是&#xff1a;两个数转为二进制&#xff0c;然后从高位开始比较&#xff0c;如果相同则为0&#xff0c;不相同则为1。 比如&#xff1a;8^11. 8转为二进制是1000&#xff0c;11转为二进制是1011.从高位开始比较得到的是&#xff…
阅读更多...
this指针不全等于对象地址

this指针不全等于对象地址

一般情况下都说this指针等于对象地址&#xff0c;当对象调用类的成员函数时&#xff0c;对象会传给成员函数一个this指针&#xff0c;也就是自己的地址来引用、标识自己。 正是在这个思想下&#xff0c;导致我调试一个问题调试了整整一天。也许是本人学艺不精&#xff0c;但是…
阅读更多...
【转】Task和async/await详解

【转】Task和async/await详解

一、什么是异步 同步和异步主要用于修饰方法。当一个方法被调用时&#xff0c;调用者需要等待该方法执行完毕并返回才能继续执行&#xff0c;我们称这个方法是同步方法&#xff1b;当一个方法被调用时立即返回&#xff0c;并获取一个线程执行该方法内部的业务&#xff0c;调用者…
阅读更多...
LeetCode每日打卡 - 反转每对括号间的子串

LeetCode每日打卡 - 反转每对括号间的子串

题解中有个更好的思路&#xff0c;stack存入的不是(的坐标&#xff0c;存入每次到左括号的字符串&#xff0c;拿到右括号就对其进行反转&#xff0c;更妙一些。 import java.util.Stack; class Solution {public String reverseParentheses(String s) {Stack<Integer> s…
阅读更多...
iar stm32_树莓派玩转STM32开发（一）——介绍篇

iar stm32_树莓派玩转STM32开发（一）——介绍篇

01—树莓派树莓派(Raspberry Pi)听起来让人流口水&#xff0c;但它的确不是吃的(身为非吃货的我第一次也以为它是食物……)。树莓派是基于ARM架构的Linux卡片电脑&#xff0c;由英国树莓派基金会开发&#xff0c;目的是以低价硬件以及自由软件来促进学校的基本电脑科学教育。树…
阅读更多...
JavaScript面向对象的理解

JavaScript面向对象的理解

前言 1. 本文默认阅读者已有面向对象的开发思想&#xff0c;最好是使用过c、java&#xff0c;本人Java不太熟悉&#xff0c;所以例子都是用C来写的。 2. 本人不是专业网站开发人员&#xff0c;接触javascript一年多&#xff0c;自己也编写调试了一些代码&#xff0c;本文完全根…
阅读更多...
【转】C# 彻底搞懂async/await

【转】C# 彻底搞懂async/await

关键&#xff1a; 异步方法&#xff1a;在执行完成前立即返回调用方法&#xff0c;在调用方法继续执行的过程中完成任务。 async/await 结构可分成三部分&#xff1a; &#xff08;1&#xff09;调用方法&#xff1a;该方法调用异步方法&#xff0c;然后在异步方法执行其任务的…
阅读更多...
LeetCode每日打卡 - 汉明距离总和

LeetCode每日打卡 - 汉明距离总和

有点慢&#xff0c;两层循环也可以完成&#xff0c;就是换个方向&#xff0c;外层遍历32大小的bits数组&#xff0c;里层遍历nums的数字每次右移一位&#xff0c;计算方法类似。 class Solution {public int totalHammingDistance(int[] nums) {//int 是4byte &#xff0c; 每…
阅读更多...
python编写代码_用 Python 编写干净、可测试、高质量的代码

python编写代码_用 Python 编写干净、可测试、高质量的代码

用 Python 编写干净、可测试、高质量的代码Noah Gift 2010 年 12 月 20 日发布简介 编写软件是人所承担的最复杂的任务之一。AWK 编程语言和 "K and R C" 的作者之一 Brian Kernigan 在 Software Tools 一书中总结了软件开发的真实性质&#xff0c;他说&#xff0c;“…
阅读更多...
cout怎么读

cout怎么读

意思是控制台输出&#xff0c;所以应该是console out&#xff0c;而不是c out。
阅读更多...
【转】WebApi中的C#await / async,重点是什么？

【转】WebApi中的C#await / async,重点是什么？

有人知道这样做的目的是什么&#xff1f; private async Task<bool> StoreAsync(TriviaAnswer answer) { ... } [ResponseType(typeof(TriviaAnswer))]public async Task<IHttpActionResult> Post(TriviaAnswer answer){var isCorrect await StoreAsync(answer);r…
阅读更多...
阿里云服务器被[kthreaddi]挖矿病毒攻击

阿里云服务器被[kthreaddi]挖矿病毒攻击

首先我根本https://blog.csdn.net/weixin_41599103/article/details/115403332这个博客试了下并没有成功&#xff0c;所以应该是被侵入的程序不一样 先去阿里云里看一下详情 明确告诉了是通过docker被攻击了&#xff0c;先将wordpress容器停止并删除容器和镜像 kill掉进行&am…
阅读更多...
python canvas画弧度_python画一朵玫瑰给你

python canvas画弧度_python画一朵玫瑰给你

听说 python 还能画画&#xff1f;是的&#xff0c;今天亲手画一朵玫瑰给你。turtle 是 python 中一个强大的绘制图像的库&#xff0c;可以用来绘制各种图像&#xff0c;使用起来很方便。但是需要计算各种角度、距离等&#xff0c;所以要想完成一幅复杂的图像还是有一定的难度的…
阅读更多...
通俗彻底解读批处理的延迟变量

通俗彻底解读批处理的延迟变量

先说环境变量 一个批处理可以看成是一个程序&#xff0c;它的环境变量就是自己的全局变量。操作系统可以看成是一个大程序&#xff0c;它的环境变量同样也是全局变量&#xff0c;只不过为了和程序的环境变量区别&#xff0c;就叫做全局环境变量了&#xff0c;既然为了区别&…
阅读更多...
LeetCode每日打卡 - 4的幂

LeetCode每日打卡 - 4的幂

不使用循环来今天解题 public boolean isPowerOfFour(int n) {return n > 0 && (n & (n-1)) 0 && n % 31;}首先去做了2的幂这道题&#xff0c;并了解了n&(n-1)的过程&#xff0c;然后思考一下这道题:求二进制中1的个数&#xff0c;理解了n&(n-…
阅读更多...
【转】探索c#之Async、Await剖析

【转】探索c#之Async、Await剖析

阅读目录&#xff1a; 基本介绍基本原理剖析内部实现剖析重点注意的地方总结 基本介绍 Async、Await是net4.x新增的异步编程方式&#xff0c;其目的是为了简化异步程序编写&#xff0c;和之前APM方式简单对比如下。 APM方式&#xff0c;BeginGetRequestStream需要传入回调函数…
阅读更多...
时间计算题100道_小学数学专项练习：计算题200道，趁早打印给孩子，期末考试拿100分！...

时间计算题100道_小学数学专项练习：计算题200道，趁早打印给孩子，期末考试拿100分！...

点击上方「升学的秘诀」关注我们&#xff01;获取更多教育经验、方法、学习资料等&#xff0c;每天中午12点与您相约&#xff01;▼说到我们数学学习过程中最重要的是什么&#xff1f;毋庸置疑那就是我们的一个计算能力&#xff0c;计算可以说是贯穿了我们整个数学学习体系&…
阅读更多...
最新文章

Copyright @ 2022~2023