这是一个基于Go语言的TCP网络服务，支持插件扩展，客户端认证和加密通信。
- 仅开放一个端口提供服务
- 支持插件系统（服务类和命令类）
- 支持插件的安装、卸载、启用、禁用和升级
- 支持客户端认证和权限控制
- 使用XXTEA加密算法进行数据加密传输
- 提供多种实用插件：
- 文件传输插件：支持文件上传下载，断点续传，压缩传输
- Shell执行插件：支持执行服务器命令
- 终端管理插件：支持管理远程终端
- 代理服务插件：支持HTTP、SOCKS4和SOCKS5代理
# 克隆仓库
git clone https://github.com/sorc/tcpserver.git
cd tcpserver
# 编译服务器
go build -o server ./cmd/server
# 编译客户端
go build -o client ./cmd/client服务器配置文件为config.json，示例：
{
"server": {
"addr": ":8888",
"plugins_dir": "plugins",
"config_dir": "config"
},
"clients": [
{
"id": "client1",
"secret": "secret1",
"name": "Default Client",
"permissions": [
"plugin:manage",
"service:manage",
"plugin:use"
]
}
]
}客户端配置文件为client.json，示例：
{
"server_addr": "localhost:8888",
"client_id": "client1",
"secret": "secret1"
}./server -config config.json./client -config client.json客户端支持以下命令：
manager list- 列出已安装的插件manager install <plugin_path>- 安装插件manager uninstall <plugin_id>- 卸载插件manager enable <plugin_id>- 启用插件manager disable <plugin_id>- 禁用插件manager info <plugin_id>- 显示插件信息file upload <request_json>- 上传文件file download <request_json>- 下载文件file list [path]- 列出文件file delete <path>- 删除文件或目录file mkdir <path>- 创建目录shell exec <command>- 执行Shell命令shell interactive- 启动交互式Shellterminal create <request_json>- 创建终端terminal list- 列出终端terminal kill <terminal_id>- 终止终端terminal write <request_json>- 向终端写入数据terminal read <terminal_id>- 从终端读取数据proxy status- 显示代理状态proxy start <proxy_type>- 启动代理服务proxy stop <proxy_type>- 停止代理服务help- 显示帮助信息exit/quit- 退出客户端
要开发新的插件，需要实现plugin.Plugin接口，并根据插件类型实现plugin.ServicePlugin或plugin.CommandPlugin接口。
package main
import (
"context"
"io"
"github.com/sorc/tcpserver/internal/plugin"
)
// MyServicePlugin 自定义服务插件
type MyServicePlugin struct {
*plugin.BaseServicePlugin
// 自定义字段
}
// Plugin 导出的插件实例
var Plugin *MyServicePlugin
func init() {
Plugin = &MyServicePlugin{
BaseServicePlugin: plugin.NewBaseServicePlugin("my-service", "My Service", "1.0.0"),
}
}
// Start 启动服务
func (p *MyServicePlugin) Start(ctx context.Context) error {
// 实现服务启动逻辑
return p.BaseServicePlugin.Start(ctx)
}
// Stop 停止服务
func (p *MyServicePlugin) Stop() error {
// 实现服务停止逻辑
return p.BaseServicePlugin.Stop()
}
*.so
func main() {}package main
import (
"context"
"fmt"
"io"
"github.com/sorc/tcpserver/internal/plugin"
)
// MyCommandPlugin 自定义命令插件
type MyCommandPlugin struct {
*plugin.BaseCommandPlugin
// 自定义字段
}
// Plugin 导出的插件实例
var Plugin *MyCommandPlugin
func init() {
Plugin = &MyCommandPlugin{
BaseCommandPlugin: plugin.NewBaseCommandPlugin("my-command", "My Command", "1.0.0", plugin.OneTimeCommand),
}
}
// GetCommands 获取支持的命令列表
func (p *MyCommandPlugin) GetCommands() []string {
return []string{
"hello",
"world",
}
}
// Execute 执行命令
func (p *MyCommandPlugin) Execute(ctx context.Context, args []string, input io.Reader, output io.Writer) error {
if len(args) == 0 {
return fmt.Errorf("no command specified")
}
command := args[0]
switch command {
case "hello":
fmt.Fprintln(output, "Hello!")
case "world":
fmt.Fprintln(output, "World!")
default:
return fmt.Errorf("unknown command: %s", command)
}
return nil
}
func main() {}