mirror of https://github.com/tp4a/teleport
temp: 配置信息界面显示数据库类型。
Apex Liu
parent
b485eb7857
commit
cb9ecebbce
|
|
@ -1,75 +0,0 @@
|
|||
# 一些想法
|
||||
|
||||
## 服务解耦
|
||||
|
||||
将core服务和web服务解耦合，让core服务不直接访问数据库。
|
||||
|
||||
优点：
|
||||
|
||||
- 简化core服务代码，不用直接访问数据库，C++访问数据库比python访问数据库代码复杂度更高。
|
||||
- 通过web提供的rpc接口来访问数据库，限定数据库访问点仅通过web进行，容易做多类型的数据库的支持，比如从sqlite迁移到mysql。
|
||||
|
||||
缺点：
|
||||
|
||||
- 需要web提供特别的rpc接口，web服务和core服务的交互增加了。
|
||||
|
||||
|
||||
|
||||
目前的core服务中直接访问数据库，涉及到
|
||||
|
||||
- 生成会话ID，需要根据认证ID获取认证信息；
|
||||
- 更新当前连接状态（连接、结束，出错等）；
|
||||
|
||||
可改为web查询数据库，然后将数据传递给core服务。_但是这里有一个潜在的安全漏洞：认证信息中包含的私密信息会在网络上传播了。_解决的办法是：如果core和web在同一台主机上，没有漏洞，如果不在同一台主机上，core需要配置一个密钥放在配置文件中，web配置时需要输入此密钥才能与指定的core连接，且传输隐秘数据时使用此密钥进行加密。
|
||||
|
||||
|
||||
|
||||
|
||||
## 会话ID
|
||||
|
||||
关于会话ID的有效期，现有版本是设置一个引用计数，对于rdp可以使用两次，而ssh只能使用一次，原因是rdp连接时，通常第一次连接用于协商子协议，然后会断开，并立即重连并使用确定好的子协议进行后续操作。
|
||||
|
||||
改进的方法是：为一个会话ID设置一个标志及一个最后活动时间，会话ID刚生成时标志为false，调用take_session()时设置为true，当连接断开时（或者未能连接成功时）重置为false并更新最后活动时间为当前时间。标志为true时不允许重复take_session()，每次调用take_session()时检查标志为false的回话ID的最后活动时间，如果超过5秒未活动，则删除此会话ID。
|
||||
|
||||
这样做可以适配各种连接方式。
|
||||
|
||||
|
||||
|
||||
## 用户体验
|
||||
|
||||
纯净安装：基本上就是复制文件，没有别的操作了。安装完成后，提示teleport的运维管理WEB服务的URL，让用户进行访问。
|
||||
|
||||
### 纯净安装
|
||||
|
||||
**尽可能使用WEB-UI进行配置**
|
||||
|
||||
完全新安装的服务端，仅启动了web服务（但是web服务的监听IP和端口如何设定？监听IP可以设置为在0.0.0.0上监听，但是端口如何设定？）。因此，端口必须用配置文件的方式进行设定。其次，对于log级别、log输出路径等设定，涉及到系统的调试（可能web服务根本就启动不了，所以无法通过web界面进行设置），因此也需要通过配置文件的方式设定。
|
||||
|
||||
core与web之间通过JSON-RPC方式进行通讯，core并不直接操作数据库，而是转由web提供RPC接口进行操作。web服务并不直接读取core的配置，而是通过core提供的RPC接口获取或修改其配置。
|
||||
|
||||
core服务提供RPC接口，能够获取其内部状态，例如当前连接数、网络IO负载等等。
|
||||
|
||||
可以通过RPC接口停止或重启core和web服务。
|
||||
|
||||
web服务启动后，访问登录页面，但是如果缺少配置数据表，就跳转到配置页面。
|
||||
|
||||
- 设定所用数据库（可选本地sqlite，或者MySQL，如果是MySQL，需要给出root权限，或者指定有权限访问的数据库和用户名及密码，以及teleport相关表的前缀，默认为“tp_”），注意，这些信息必须存放在配置文件中，因此配置文件需要支持写入操作；
|
||||
- 创建配置数据库（包括用户表、配置表等）;
|
||||
- 设定管理员密码（管理员用户名固定为admin）；
|
||||
- 设置core服务的地址和端口（默认是本机127.0.0.1，端口包括RPC端口、SSH/RDP/Telnet端口等）；
|
||||
- 设定core服务存放日志回放记录文件的目录地址；
|
||||
- core和web的配置信息均存放在.ini配置文件中，方便特定情况下用户手工编辑；
|
||||
|
||||
|
||||
安装时需要用户选择安装core还是web，还是二者皆安装。
|
||||
|
||||
安装完成后，core服务和web服务均会启动，在第一次启动时，需要创建config数据库，里面是一堆空表，只有用户表里面有一个管理员账号admin，安装部署人员可以使用此账号登陆系统。
|
||||
|
||||
需要增强服务的自检功能，例如端口已经被占用等，需要在日志中给出明确的错误信息。另外，考虑到将来core服务可能部署到多个主机上以提升承载能力，所以web需要访问core的数据时（包括取日志回放文件数据等），均使用RPC接口进行。
|
||||
|
||||
第一次登陆系统，会自动跳转到配置向导界面，让用户一步一步进行服务器配置。
|
||||
|
||||
|
||||
|
||||
-
|
||||
|
||||
|
|
@ -88,7 +88,7 @@ class ConfigFile(AttrDict):
|
|||
return True
|
||||
|
||||
def update_core(self, conf_data):
|
||||
log.d('update core server config info.\n')
|
||||
# log.d('update core server config info.\n')
|
||||
self['core'] = AttrDict()
|
||||
|
||||
if conf_data is None:
|
||||
|
|
|
|||
|
|
@ -78,6 +78,7 @@ class WebServerCore:
|
|||
rep = urllib.request.urlopen(req, timeout=3)
|
||||
body = rep.read().decode()
|
||||
x = json.loads(body)
|
||||
log.d('update core server config info.\n')
|
||||
cfg.update_core(x['data'])
|
||||
except:
|
||||
log.w('can not connect to core server to get config, maybe it not start yet, ignore.\n')
|
||||
|
|
|
|||
|
|
@ -123,6 +123,7 @@ class RpcHandler(TPBaseJsonHandler):
|
|||
if return_data['code'] != 0:
|
||||
return self.write_json(-3, 'get config from core service return code: {}'.format(return_data['code']))
|
||||
|
||||
log.d('update core server config info.\n')
|
||||
app_cfg().update_core(return_data['data'])
|
||||
|
||||
return self.write_json(0)
|
||||
|
|
|
|||
|
|
@ -5,6 +5,7 @@ import tornado.gen
|
|||
import tornado.httpclient
|
||||
|
||||
from eom_ver import *
|
||||
from eom_app.app.db import get_db
|
||||
from eom_app.app.configs import app_cfg
|
||||
from eom_app.app.util import *
|
||||
from .base import TPBaseAdminAuthHandler, TPBaseAdminAuthJsonHandler
|
||||
|
|
@ -30,11 +31,19 @@ class InfoHandler(TPBaseAdminAuthHandler):
|
|||
if not core_detected:
|
||||
cfg.update_core(None)
|
||||
|
||||
_db = get_db()
|
||||
database = '未知'
|
||||
if _db.db_source['type'] == _db.DB_TYPE_SQLITE:
|
||||
database = 'SQLite（{}）'.format(_db.db_source['file'])
|
||||
elif _db.db_source['type'] == _db.DB_TYPE_MYSQL:
|
||||
database = 'MySQL'
|
||||
|
||||
param = {
|
||||
'core': cfg.core,
|
||||
'web': {
|
||||
'version': TS_VER,
|
||||
'core_server_rpc': cfg['core_server_rpc']
|
||||
'core_server_rpc': cfg['core_server_rpc'],
|
||||
'database': database
|
||||
}
|
||||
}
|
||||
self.render('set/info.mako', page_param=json.dumps(param))
|
||||
|
|
|
|||
|
|
@ -17,12 +17,13 @@ ywl.on_init = function (cb_stack, cb_args) {
|
|||
html.push(ywl._make_info('核心服务版本', ywl.page_options.core.version));
|
||||
}
|
||||
|
||||
html.push(ywl._make_info('数据库类型', ywl.page_options.web.database));
|
||||
html.push(ywl._make_info('核心服务通讯地址', ywl.page_options.web.core_server_rpc));
|
||||
if (ywl.page_options.core.detected) {
|
||||
html.push(ywl._make_info('WEB服务通讯地址', ywl.page_options.core.web_server_rpc));
|
||||
html.push(ywl._make_protocol_info('RDP 端口', ywl.page_options.core.rdp));
|
||||
html.push(ywl._make_protocol_info('SSH 端口', ywl.page_options.core.ssh));
|
||||
html.push(ywl._make_protocol_info('TELNET 端口', ywl.page_options.core.telnet));
|
||||
// html.push(ywl._make_protocol_info('TELNET 端口', ywl.page_options.core.telnet));
|
||||
html.push(ywl._make_info('录像文件路径', ywl.page_options.core.replay_path));
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue