blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-10-25 20:52:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

improve stress tools.

Browse Source
This commit is contained in:
Monet Lee 2025-04-23 16:20:40 +08:00
parent c8c3723f90
commit 13cd8c759a
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
test/stress-test-v2/main.go
View File

@ -161,7 +161,7 @@ func (st *StressTest) PostRequest(ctx context.Context, url string, reqbody any)
if baseResp.ErrCode != 0 { if baseResp.ErrCode != 0 {
err = fmt.Errorf(baseResp.ErrMsg) err = fmt.Errorf(baseResp.ErrMsg)
log.ZError(ctx, "Failed to send request", err, "url", url, "reqbody", reqbody, "resp", baseResp) // log.ZError(ctx, "Failed to send request", err, "url", url, "reqbody", reqbody, "resp", baseResp)
return nil, err return nil, err
} }
@ -530,9 +530,20 @@ func main() {
// Create 100K groups // Create 100K groups
st.Wg.Add(1) st.Wg.Add(1)
go func(idx int) { go func(idx int) {
startTime := time.Now()
defer func() {
elapsedTime := time.Since(startTime)
log.ZInfo(st.Ctx, "100K group creation completed",
"groupID", fmt.Sprintf("v2_StressTest_Group_100K_%d", idx),
"index", idx,
"duration", elapsedTime.String())
}()
defer st.Wg.Done() defer st.Wg.Done()
defer func() { defer func() {
st.Mutex.Lock()
st.Create100kGroupCounter++ st.Create100kGroupCounter++
st.Mutex.Unlock()
}() }()
groupID := fmt.Sprintf("v2_StressTest_Group_100K_%d", idx) groupID := fmt.Sprintf("v2_StressTest_Group_100K_%d", idx)
@ -556,7 +567,7 @@ func main() {
} }
if len(InviteUserIDs) == 0 { if len(InviteUserIDs) == 0 {
log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID) // log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID)
continue continue
} }
@ -567,7 +578,7 @@ func main() {
} }
if len(InviteUserIDs) == 0 { if len(InviteUserIDs) == 0 {
log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID) // log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID)
continue continue
} }
@ -602,9 +613,20 @@ func main() {
// Create 999 groups // Create 999 groups
st.Wg.Add(1) st.Wg.Add(1)
go func(idx int) { go func(idx int) {
startTime := time.Now()
defer func() {
elapsedTime := time.Since(startTime)
log.ZInfo(st.Ctx, "999 group creation completed",
"groupID", fmt.Sprintf("v2_StressTest_Group_1K_%d", idx),
"index", idx,
"duration", elapsedTime.String())
}()
defer st.Wg.Done() defer st.Wg.Done()
defer func() { defer func() {
st.Mutex.Lock()
st.Create999GroupCounter++ st.Create999GroupCounter++
st.Mutex.Unlock()
}() }()
groupID := fmt.Sprintf("v2_StressTest_Group_1K_%d", idx) groupID := fmt.Sprintf("v2_StressTest_Group_1K_%d", idx)
@ -627,7 +649,7 @@ func main() {
} }
if len(InviteUserIDs) == 0 { if len(InviteUserIDs) == 0 {
log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID) // log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID)
continue continue
} }
@ -638,7 +660,7 @@ func main() {
} }
if len(InviteUserIDs) == 0 { if len(InviteUserIDs) == 0 {
log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID) // log.ZWarn(st.Ctx, "InviteUserIDs is empty", nil, "groupID", groupID)
continue continue
} }