diff --git a/src/chat/message_manager/distribution_manager.py b/src/chat/message_manager/distribution_manager.py index 44c48376a..ff06ec5d3 100644 --- a/src/chat/message_manager/distribution_manager.py +++ b/src/chat/message_manager/distribution_manager.py @@ -34,8 +34,8 @@ class StreamLoopManager: } # 配置参数 - self.max_concurrent_streams = max_concurrent_streams or getattr( - global_config.chat, "max_concurrent_distributions", 10 + self.max_concurrent_streams = ( + max_concurrent_streams or global_config.chat.max_concurrent_distributions ) # Chatter管理器 diff --git a/src/config/official_configs.py b/src/config/official_configs.py index 1dd517834..3615f49a7 100644 --- a/src/config/official_configs.py +++ b/src/config/official_configs.py @@ -158,6 +158,9 @@ class ChatConfig(ValidatedConfigBase): dynamic_distribution_jitter_factor: float = Field( default=0.2, ge=0.0, le=0.5, description="分发间隔随机扰动因子" ) + max_concurrent_distributions: int = Field( + default=10, ge=1, le=100, description="最大并发处理的消息流数量" + ) def get_current_talk_frequency(self, chat_stream_id: Optional[str] = None) -> float: """ diff --git a/template/bot_config_template.toml b/template/bot_config_template.toml index 4b08c8cd0..d9d94a06d 100644 --- a/template/bot_config_template.toml +++ b/template/bot_config_template.toml @@ -1,5 +1,5 @@ [inner] -version = "7.0.2" +version = "7.0.3" #----以下是给开发人员阅读的,如果你只是部署了MoFox-Bot,不需要阅读---- #如果你想要修改配置文件,请递增version的值 @@ -131,6 +131,7 @@ dynamic_distribution_base_interval = 5.0 # 基础分发间隔(秒) dynamic_distribution_min_interval = 1.0 # 最小分发间隔(秒) dynamic_distribution_max_interval = 30.0 # 最大分发间隔(秒) dynamic_distribution_jitter_factor = 0.2 # 分发间隔随机扰动因子 +max_concurrent_distributions = 10 # 最大并发处理的消息流数量,可以根据API性能和服务器负载调整 talk_frequency_adjust = [ ["", "8:00,1", "12:00,1.2", "18:00,1.5", "01:00,0.6"],