codegeex生成kafka/rabbitmq生产者脚本失败的主因是提示词模糊、库版本不匹配及关键参数（如durable=true、delivery_mode=2、.encode('utf-8')）缺失；需严格按格式输入提示词、手动补全序列化与持久化配置，并通过docker-compose启动服务后验证。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜
你需要在 VSCode 里用 CodeGeeX 生成一条可直接运行的 Kafka 或 RabbitMQ 生产者脚本，但复制粘贴后总报错、连不上服务、消息发不出去——问题往往出在提示词模糊、库版本没对齐、关键参数被模型漏掉，而不是模型本身不行。
确认插件状态与基础环境
打开 VSCode，点击左侧活动栏最下方的方块图标（Extensions），在搜索框输入 CodeGeeX，确认已安装且右侧火箭图标可见。若图标未出现，说明插件未启用或被误拖出侧边栏——此时点击菜单栏【查看】→【视图】→ 搜索并勾选 “CodeGeeX” 即可恢复。
确保 VSCode 版本 ≥ 1.75.0；终端执行 code --version 可验证。低于该版本可能触发插件兼容性错误，【无法加载 CodeGeeX 功能面板】。
检查本地是否已安装对应语言运行时：Python 项目需有 pip，Go 项目需有 go 命令，且网络可访问 PyPI 或 Go Proxy。
生成 Kafka 生产者（confluent-kafka 方案）
方法一：精准提示词驱动生成
在空白 .py 文件中，光标置于首行，输入以下提示词（严格按格式，不可换行）：
“生成一个 Python 脚本，使用 confluent-kafka==2.4.0，连接 localhost:9092，向 topic-1 发送 3 条 JSON 消息，每条含 timestamp（当前时间戳）和 value（字符串），启用 delivery report 回调，超时设为 5 秒。”
按下 Ctrl+Enter 触发交互模式，从右侧候选中选择第一个结果。若生成代码未包含 import json 或未对 value 执行 .encode('utf-8')，必须手动补全——否则会抛出 TypeError: expected bytes, got dict。
方法二：补全关键序列化逻辑
找到 producer.produce(…) 行，在其上方插入：value = json.dumps({"timestamp": int(time.time()), "value": f"msg-{i}"}).encode("utf-8")；同时确保顶部有 import json, time。这一步漏掉，脚本必然崩溃。
微软正式发布 Visual Studio Code 1.118 版本 。本次更新重点强化了 AI 开发体验与企业管理能力，其中最引人注目的是新增 Copilot CLI 远程控制功能，允许开发者通过手机或网页远程监控和接管 AI 会话 。同时，为了提高 AI 的运行性价比，新版本优化了令牌缓存策略以降低成本 。此外，1.118 版还引入了 Chronicle 本地历史追踪、TypeScript 7.0 支持以及更严格的企业级访问管控 。
生成 RabbitMQ 生产者（pika 同步方案）
第一步：声明持久化队列不可省略
在新 .py 文件中输入提示词：“用 Python 和 pika 连接 localhost:5672，默认 vhost /，用户 guest，密码 guest；声明名为 task_queue 的持久化队列；发送一条内容为 ‘Hello from CodeGeeX’ 的持久化消息。”
第二步：强制校验 durable 参数
生成代码后，立即定位到 channel.queue_declare(queue='task_queue') 这一行——【若无 durable=True 参数，此消息将无法在 RabbitMQ 重启后存活】。手动补上，变成 channel.queue_declare(queue='task_queue', durable=True)。
第三步：消息属性必须显式设置
检查 channel.basic_publish() 调用，确认 properties 参数传入了 pika.BasicProperties(delivery_mode=2)。delivery_mode=2 是持久化消息的唯一标识，缺它则消息仅存于内存，断电即丢。
一键验证与调试路径
① 先运行 docker-compose up -d 启动配套环境（如你已生成过 docker-compose.yml）；等待 30 秒让服务就绪。
② 在 VSCode 终端中执行生成的生产者脚本，观察终端输出是否含 “delivered” 或 “sent”。若报错 ConnectionRefusedError，说明目标服务未启动或端口被占用。
③ 若脚本静默退出无报错但消息未到达，立刻打开浏览器访问 http://localhost:15672（RabbitMQ 管理界面）或 http://localhost:9092/actuator（Kafka REST Proxy），确认 topic/queue 是否真实创建、是否有消费者绑定。
④ 对 Kafka 场景，额外执行 kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-1 --from-beginning 实时监听，验证消息是否真正发出。
