为什么 Producer 一路下来全部依赖 mut self?

[l-7-l]

是否可以完全避免mut, 比如这里 完全没看到 mut的必要

    fn process_send_response<T>(
        &mut self,
        broker_name: &CheetahString,
        msg: &T,
        response: &RemotingCommand,
        addr: &CheetahString,
    ) -> rocketmq_error::RocketMQResult<SendResult>
    where
        T: MessageTrait,
    {
        let response_code = ResponseCode::from(response.code());
        let send_status = match response_code {
            ResponseCode::FlushDiskTimeout => SendStatus::FlushDiskTimeout,
            ResponseCode::FlushSlaveTimeout => SendStatus::FlushSlaveTimeout,
            ResponseCode::SlaveNotAvailable => SendStatus::SlaveNotAvailable,
            ResponseCode::Success => SendStatus::SendOk,
            _ => {
                return Err(client_broker_err!(
                    response.code(),
                    response.remark().map_or("".to_string(), |s| s.to_string()),
                    addr.to_string()
                ))
            }
        };
        let response_header = response
            .decode_command_custom_header_fast::<SendMessageResponseHeader>()
            .unwrap();
        let mut topic = msg.topic().to_string();
        if let Some(ns) = self.client_config.get_namespace_v2() {
            if !ns.is_empty() {
                topic = NamespaceUtil::without_namespace_with_namespace(topic.as_str(), ns.as_str());
            }
        }
        let message_queue = MessageQueue::from_parts(topic.as_str(), broker_name, response_header.queue_id());
        let mut uniq_msg_id = MessageClientIDSetter::get_uniq_id(msg);
        let msgs = msg.as_any().downcast_ref::<MessageBatch>();

        if let (Some(msgs), true) = (msgs, response_header.batch_uniq_id().is_none()) {
            let mut sb = String::new();
            for msg in &msgs.messages {
                sb.push_str(if sb.is_empty() { "" } else { "," });
                sb.push_str(MessageClientIDSetter::get_uniq_id(msg).unwrap().as_str());
            }
            uniq_msg_id = Some(CheetahString::from_string(sb));
        }

        let region_id = response
            .ext_fields()
            .unwrap()
            .get(MessageConst::PROPERTY_MSG_REGION)
            .map_or(mix_all::DEFAULT_TRACE_REGION_ID.to_string(), |s| s.to_string());
        let trace_on = response
            .ext_fields()
            .unwrap()
            .get(MessageConst::PROPERTY_TRACE_SWITCH)
            .is_some_and(|s| s.parse().unwrap_or(false));
        let send_result = SendResult {
            send_status,
            msg_id: uniq_msg_id,
            offset_msg_id: Some(response_header.msg_id().to_string()),
            message_queue: Some(message_queue),
            queue_offset: response_header.queue_offset() as u64,
            transaction_id: response_header.transaction_id().map(|s| s.to_string()),
            recall_handle: response_header.recall_handle().map(|s| s.to_string()),
            region_id: Some(region_id),
            trace_on,
            ..Default::default()
        };

        Ok(send_result)
    }

[mxsm]

@l-7-l 之前的想法是避免后期需要用到所以用的&mut self

[l-7-l]

@mxsm 要不要去掉 mut 我貌似可以帮忙

[l-7-l]

感觉有点麻烦，如果放到 axum state里 我是加锁还是不加锁,

[mxsm]

@l-7-l 暂时还是不要去掉！后续这个还需要进行优化！

[l-7-l]

@mxsm 谢谢同志，大佬现在建议接入生产了吗? 如果建议接入, 有什么需要注意的坑么?

[mxsm]

@mxsm 谢谢同志，大佬现在建议接入生产了吗? 如果建议接入, 有什么需要注意的坑么?

@l-7-l 目前如果只是使用基础的功能是没什么问题。但是还不建议接入生产，还需要对整个进行系统的测试。最近会发布0.9的版本，等1.0版本发布是第一个生成可用的版本。如果你是机器的内存不够用可以尝试使用Rust版本，因为内存使用比Java低很多

[albertbolt1]

is the rust version going to be deployed in prod somewhere ?

[mxsm]

is the rust version going to be deployed in prod somewhere ?

@albertbolt1 Yes, but it should not be in production yet. Most of the features are already completed! Next is further testing and validation.

[DuJiming]

@mxsm 大佬，1.0有大致发布时间吗，我看我们能不能赶上，不然就只能用官方的5.0缝缝补补上去对付了。。。

[mxsm]

@mxsm 大佬，1.0有大致发布时间吗，我看我们能不能赶上，不然就只能用官方的5.0缝缝补补上去对付了。。。

@DuJiming 争取九月份之前发布，目前做了重构，然后再做测试和性能测试。