chore: 更新版本号至 v1.1.3
增加 version host_name 2个新字段传递
This commit is contained in:
10
README.md
10
README.md
@@ -337,8 +337,8 @@ BACKEND_URL=http://192.168.1.100:8080 ./run.sh start
|
|||||||
版本号统一从 `version.json` 文件读取:
|
版本号统一从 `version.json` 文件读取:
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"version": "1.1.2",
|
"version": "1.1.3",
|
||||||
"tag": "v1.1.2"
|
"tag": "v1.1.3"
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -414,8 +414,8 @@ BACKEND_URL=http://192.168.1.100:8080 ./run.sh start
|
|||||||
版本号和标签统一从 `version.json` 文件读取:
|
版本号和标签统一从 `version.json` 文件读取:
|
||||||
```json
|
```json
|
||||||
{
|
{
|
||||||
"version": "1.1.2",
|
"version": "1.1.3",
|
||||||
"tag": "v1.1.2"
|
"tag": "v1.1.3"
|
||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -605,7 +605,7 @@ tail -n 100 node.log
|
|||||||
|
|
||||||
## 更新日志
|
## 更新日志
|
||||||
|
|
||||||
### v1.1.2 (最新)
|
### v1.1.3 (最新)
|
||||||
|
|
||||||
**新增功能:**
|
**新增功能:**
|
||||||
- ✨ 添加日志文件输出功能,支持配置日志文件路径和级别
|
- ✨ 添加日志文件输出功能,支持配置日志文件路径和级别
|
||||||
|
|||||||
@@ -7,6 +7,8 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"net/url"
|
||||||
|
"os"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -110,10 +112,25 @@ func (r *Reporter) Stop() {
|
|||||||
close(r.stopCh)
|
close(r.stopCh)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// buildHeartbeatBody 构建心跳请求体
|
||||||
|
func buildHeartbeatBody() string {
|
||||||
|
hostname, err := os.Hostname()
|
||||||
|
if err != nil {
|
||||||
|
hostname = "unknown"
|
||||||
|
}
|
||||||
|
|
||||||
|
values := url.Values{}
|
||||||
|
values.Set("type", "pingServer")
|
||||||
|
values.Set("version", "2")
|
||||||
|
values.Set("host_name", hostname)
|
||||||
|
|
||||||
|
return values.Encode()
|
||||||
|
}
|
||||||
|
|
||||||
// RegisterNode 注册节点(安装时或首次启动时调用)
|
// RegisterNode 注册节点(安装时或首次启动时调用)
|
||||||
func RegisterNode(cfg *config.Config) error {
|
func RegisterNode(cfg *config.Config) error {
|
||||||
url := fmt.Sprintf("%s/api/node/heartbeat", cfg.Backend.URL)
|
url := fmt.Sprintf("%s/api/node/heartbeat", cfg.Backend.URL)
|
||||||
req, err := http.NewRequest("POST", url, bytes.NewBufferString("type=pingServer"))
|
req, err := http.NewRequest("POST", url, bytes.NewBufferString(buildHeartbeatBody()))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("创建心跳请求失败: %w", err)
|
return fmt.Errorf("创建心跳请求失败: %w", err)
|
||||||
}
|
}
|
||||||
@@ -193,7 +210,7 @@ func RegisterNode(cfg *config.Config) error {
|
|||||||
func (r *Reporter) sendHeartbeat() {
|
func (r *Reporter) sendHeartbeat() {
|
||||||
// 发送心跳(使用Form格式,兼容旧接口)
|
// 发送心跳(使用Form格式,兼容旧接口)
|
||||||
url := fmt.Sprintf("%s/api/node/heartbeat", r.cfg.Backend.URL)
|
url := fmt.Sprintf("%s/api/node/heartbeat", r.cfg.Backend.URL)
|
||||||
req, err := http.NewRequest("POST", url, bytes.NewBufferString("type=pingServer"))
|
req, err := http.NewRequest("POST", url, bytes.NewBufferString(buildHeartbeatBody()))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
r.logger.Error("创建心跳请求失败", zap.Error(err))
|
r.logger.Error("创建心跳请求失败", zap.Error(err))
|
||||||
return
|
return
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
{
|
{
|
||||||
"version": "1.1.2",
|
"version": "1.1.3",
|
||||||
"tag": "v1.1.2"
|
"tag": "v1.1.3"
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user