lib/ConnTool.py · shenguo/frp-python

代码拉取完成,页面将自动刷新

扫描微信二维码支付

取消

支付完成

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 7

shenguo/frp-python

forked from usualheart/frp-python

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

master

分支 (1)

管理

master

该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。

项目仓库所选许可证以仓库主分支所使用许可证为准

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 1

标签 0

frp-python

lib

ConnTool.py

ConnTool.py 2.07 KB

# -*- coding: utf-8 -*-
# tcp mapping

import sys
import socket
import logging
import threading

# 接收数据缓存大小
PKT_BUFF_SIZE = 10240

logger = logging.getLogger("Proxy Logging")
formatter = logging.Formatter('%(name)-12s %(asctime)s %(levelname)-8s %(lineno)-4d %(message)s', '%Y %b %d %a %H:%M:%S',)

stream_handler = logging.StreamHandler(sys.stderr)
stream_handler.setFormatter(formatter)
logger.addHandler(stream_handler)
logger.setLevel(logging.DEBUG)

# 单向流数据传递
def tcp_mapping_worker(conn_receiver, conn_sender):
 logger.info("start ")
 while True:
 try:
 data = conn_receiver.recv(PKT_BUFF_SIZE)
 except Exception as e:
 logger.debug(e)
 logger.debug('Connection closed.')
 break

if not data:
 logger.info('No more data is received.') # 正常情况下不会到这,一般是某个连接断了
 break

try:
 conn_sender.sendall(data)
 except Exception:
 logger.error('Failed sending data.')
 break

# logger.info('Mapping data > %s ' % repr(data))
 # logger.info('Mapping > %s -> %s > %d bytes.' % (conn_receiver.getpeername(), conn_sender.getpeername(), len(data)))

conn_receiver.close()
 conn_sender.close()

return

# 端口映射请求处理
def join(connA, connB):
 threading.Thread(target=tcp_mapping_worker, args=(connA, connB)).start()
 threading.Thread(target=tcp_mapping_worker, args=(connB, connA)).start()
 return

if __name__ == '__main__':
 # 测试
 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 sock.bind(('0.0.0.0', 8080))
 # sock.setblocking(False)
 sock.listen(100)
 conn1,addr1 =sock.accept()

sock2 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 sock2.bind(('0.0.0.0', 7000))
 sock2.listen(100)

# 类似frpc
 server_conn = socket.create_connection(('localhost', 7000))

conn2,addr2 =sock2.accept()
 join(conn1,conn2)

target_conn = socket.create_connection(('192.168.1.101', 3389))
 join(server_conn,target_conn)

一键复制编辑原始数据按行查看历史

yyb 提交于 2022年02月23日 22:23 +08:00 . v0.1.0

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75

# -*- coding: utf-8 -*-
# tcp mapping 

import sys
import socket
import logging
import threading

# 接收数据缓存大小
PKT_BUFF_SIZE = 10240

logger = logging.getLogger("Proxy Logging")
formatter = logging.Formatter('%(name)-12s %(asctime)s %(levelname)-8s %(lineno)-4d %(message)s', '%Y %b %d %a %H:%M:%S',)

stream_handler = logging.StreamHandler(sys.stderr)
stream_handler.setFormatter(formatter)
logger.addHandler(stream_handler)
logger.setLevel(logging.DEBUG)

# 单向流数据传递
def tcp_mapping_worker(conn_receiver, conn_sender):
 logger.info("start ")
 while True:
 try:
 data = conn_receiver.recv(PKT_BUFF_SIZE)
 except Exception as e:
 logger.debug(e)
 logger.debug('Connection closed.')
 break

 if not data:
 logger.info('No more data is received.') # 正常情况下不会到这,一般是某个连接断了
 break

 try:
 conn_sender.sendall(data)
 except Exception:
 logger.error('Failed sending data.')
 break

 # logger.info('Mapping data > %s ' % repr(data))
 # logger.info('Mapping > %s -> %s > %d bytes.' % (conn_receiver.getpeername(), conn_sender.getpeername(), len(data)))

 conn_receiver.close()
 conn_sender.close()

 return


# 端口映射请求处理
def join(connA, connB):
 threading.Thread(target=tcp_mapping_worker, args=(connA, connB)).start()
 threading.Thread(target=tcp_mapping_worker, args=(connB, connA)).start()
 return

if __name__ == '__main__':
 # 测试
 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 sock.bind(('0.0.0.0', 8080))
 # sock.setblocking(False)
 sock.listen(100)
 conn1,addr1 =sock.accept()

 sock2 = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 sock2.bind(('0.0.0.0', 7000))
 sock2.listen(100)

 # 类似frpc
 server_conn = socket.create_connection(('localhost', 7000))

 conn2,addr2 =sock2.accept()
 join(conn1,conn2)

 target_conn = socket.create_connection(('192.168.1.101', 3389))
 join(server_conn,target_conn)