通义灵码可基于自然语言生成rabbitmq/kafka生产者与消费者代码：支持自动配置序列化器、重试、ack、死信队列及确认机制，但需前置引入对应依赖并正确配置连接参数与group.id等关键项。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜
你想在Java项目里快速生成RabbitMQ或Kafka的生产者、消费者代码，但又不想手动写模板、配序列化器、漏掉重试或ACK逻辑——通义灵码能直接根据自然语言描述生成可运行的队列集成代码。
用通义灵码生成RabbitMQ生产者代码
第一步：确保项目中已引入spring-boot-starter-amqp依赖，且application.yml里配置了基础连接参数（host/port/username/password），否则生成的代码会缺少连接上下文，运行时抛ConnectionFactory空指针异常。
第二步：在IDE中打开任意Java文件，光标定位到类定义外空白处，输入指令：“生成RabbitMQ生产者，向topic.exchange发送JSON订单消息，路由键为order.created，启用消息持久化和确认回调”。
第三步：通义灵码会输出含@Bean声明RabbitTemplate的配置类，并在发送方法中自动注入MessagePostProcessor设置deliveryMode=2，同时绑定CorrelationData实现发送端确认。这一步不能跳过——没有CorrelationData，你将无法感知消息是否真正抵达Broker。
用通义灵码生成Kafka消费者（Spring Kafka路径）
方法一：依赖识别自动生成
确认pom.xml中存在spring-kafka，通义灵码会优先走Spring Kafka路径。输入：“生成Kafka消费者，监听user-events主题，使用StringDeserializer，手动提交offset，消费失败时记录日志并跳过”。它将生成带@KafkaListener注解的类，并在方法内调用acknowledgment.acknowledge()，且enable.auto.commit=false已写入配置。
通义灵码 Linux版是阿里云推出的一款AI智能编码助手，专为Linux开发者设计。它支持在Linux操作系统下的JetBrains IDEs、Visual Studio Code等主流集成开发环境中运行。该工具基于通义大模型，提供代码智能生成、实时续写、单元测试生成、代码优化以及研发智能问答等功能，旨在帮助Linux用户在编码过程中提升效率。
方法二：原生客户端 fallback
若项目只含kafka-clients而无Spring Kafka，通义灵码会切换为原生模式：生成KafkaConsumer实例、手动poll()循环、commitSync()调用，以及seek()容错逻辑。此时group.id必须显式传入Properties，否则消费者无法加入组——【不填group.id会导致消费者静默启动、不拉取消息】。
生成带死信队列的RabbitMQ消费者
① 在application.yml中补全DLQ相关配置：spring.rabbitmq.listener.simple.retry.enabled=true，并设置max-attempts=3与initial-interval=3000；
② 输入自然语言指令：“生成RabbitMQ消费者，监听queue.order.process，手动ACK，消费失败时转发至dlq.order.process，且DLQ需绑定死信交换机dlx.order”；
③ 通义灵码输出的类中，@RabbitListener注解会包含containerFactory="dlqContainerFactory"，且自动声明QueueBuilder.durable("dlq.order.process").withArgument("x-dead-letter-exchange", "dlx.order")——这步若遗漏，消息进DLQ后将无法被下游监听；
④ 检查生成方法体内是否含channel.basicAck()与channel.basicNack(deliveryTag, false, false)，第二个false代表不重入队列，这是防止死循环的关键开关。
