wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3345: 设置群上限

Browse Source
This commit is contained in:
yanglin 2025-02-06 10:58:24 +08:00
parent f18d4a025a
commit 22c31ef7bb
3 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
im-center-server/src/main/java/cn/axzo/im/group/GroupProps.java
View File

@ -1,6 +1,7 @@
package cn.axzo.im.group;
import com.alibaba.fastjson.JSON;
import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
@ -10,13 +11,14 @@ import org.springframework.context.annotation.Configuration;
* @author yanglin
*/
@Setter
@Getter
@RefreshScope
@Configuration
@ConfigurationProperties(prefix = "im-group")
public class GroupProps {
public int defaultMemberLimit = 499;
public int syncMessageTps = 20;
private int defaultMemberLimit = 499;
private int syncMessageTps = 20;
@Override
public String toString() {

3
im-center-server/src/main/java/cn/axzo/im/group/GroupSupport.java
View File

@ -38,7 +38,8 @@ public class GroupSupport implements GroupLogger {
group.setAvatar(request.getAvatar());
group.setMemberCount((long) request.getOwnerAndMembers().size());
Long memberLimit = request.getMemberLimit();
group.setMemberLimit(memberLimit == null ? groupProps.defaultMemberLimit : memberLimit);
group.setMemberLimit(memberLimit == null
? groupProps.getDefaultMemberLimit() : memberLimit);
group.setOwnerAccount(owner);
group.setOwnerPersonId(request.getOwner().personIdAsLong());
group.setCreatePersonId(request.getOwner().personIdAsLong());

2
im-center-server/src/main/java/cn/axzo/im/group/message/GroupMessageSyncJob.java
View File

@ -125,7 +125,7 @@ public class GroupMessageSyncJob implements InitializingBean {
@Override
public void afterPropertiesSet() {
tps = groupProps.syncMessageTps;
tps = groupProps.getSyncMessageTps();
executor = Executors.newFixedThreadPool(
tps + 1, new NamedThreadFactory(GroupMessageSyncJob.class.getName()));
}