diff --git a/package/gamelog/test/gamelog_test.go b/package/gamelog/test/gamelog_test.go index 354662f..f68c2c9 100644 --- a/package/gamelog/test/gamelog_test.go +++ b/package/gamelog/test/gamelog_test.go @@ -57,8 +57,10 @@ func TestGamelog(t *testing.T) { func TestPressMQ(t *testing.T) { glsdk, err := gamelog.INIT(&gamelog.SDKConfig{ // 必填 - Pid: "yotest", // 项目ID - BaseUrl: "http://47.77.200.131:10101", // 美国BIDB服务器 + Pid: "ydspress", // 项目ID + // BaseUrl: "http://47.77.200.131:10101", // 美国BIDB服务器 + // BaseUrl: "http://101.37.28.111:10101", // 国内yoyatime服务器BIDB服务器 + BaseUrl: "http://47.77.206.131:10201", // 压测服务器 ReportSk: "sngame2025", // xor混淆key FlushInterval: 6, // 上报间隔 DiskBakPath: "gamelog", // 本地磁盘备份, 用于意外情况下临时保存日志, 请确保该目录持久化(容器内要挂载). 每次启动时或每N次上报时加载到失败队列 @@ -69,12 +71,22 @@ func TestPressMQ(t *testing.T) { }) // 随机测试事件和属性 - events := []string{"e1", "e2", "e3", "e4"} - pms := []map[string]any{ - {"a": "1"}, - {"a": "2"}, - {"a": "3"}, - {"a": "4"}, + // events := []string{"e1", "e2", "e3", "e4"} + // pms := []map[string]any{ + // {"s1": gconv.String(grand.Intn(100))}, + // {"s2": gconv.String(grand.Intn(300))}, + // {"s3": gconv.String(grand.Intn(500))}, + // {"i1": grand.Intn(1000000)}, + // {"i2": grand.Intn(9000000)}, + // {"f1": gconv.Float64(grand.Intn(1000)) + (gconv.Float64(grand.Intn(1000000)) / 1000.0)}, + // {"f2": gconv.Float64(grand.Intn(9000)) + (gconv.Float64(grand.Intn(1000000)) / 1000.0)}, + // {"b1": true}, + // {"b2": false}, + // } + + testProp := map[string]any{ + "version": "1.18", + "country": "ZH-CN", } uuids := []string{} for i := 0; i < 100; i++ { @@ -86,11 +98,12 @@ func TestPressMQ(t *testing.T) { t.Fatal(err) } n := 0 - const limit = 30000 + const limit = 20000 gtest.C(t, func(t *gtest.T) { go func() { for { - glsdk.LogLtz(uuids[grand.Intn(len(uuids))], events[grand.Intn(len(events))], pms[grand.Intn(len(pms))]) + // glsdk.LogLtz(uuids[grand.Intn(len(uuids))], events[grand.Intn(len(events))], pms[grand.Intn(len(pms))]) + glsdk.LogLtz(uuids[grand.Intn(len(uuids))], "PKGame:Default:StepComplete:1:1010", testProp) // 并发控制 n++ if n%limit == 0 { @@ -98,7 +111,7 @@ func TestPressMQ(t *testing.T) { } } }() - time.Sleep(time.Second * 120) + time.Sleep(time.Second * 1200) // 模拟等待信号后优雅关闭 glsdk.Shutdown() })