使用阿里开源的Spring Cloud Alibaba AI开发第一个大模型应用

import com.aliyun.openservices.ons.api.Action;
import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.MessageListener;
import com.aliyun.openservices.ons.api.ONSFactory;
import java.util.Properties;
 
public class ExampleMessageListener implements MessageListener {
 
    @Override
    public Action consume(Message message, ConsumeContext context) {
        System.out.println("Receive message: " + message);
        // 处理业务逻辑
        // ...
 
        // 返回成功消费的标识
        return Action.CommitMessage;
    }
 
    public static void main(String[] args) {
        Properties properties = new Properties();
        properties.put(PropertyKeyConst.ProducerId, "Please_replace_group_name_here");
        properties.put(PropertyKeyConst.AccessKey, "LK***********ySJ");
        properties.put(PropertyKeyConst.SecretKey, "*****************************");
        properties.put(PropertyKeyConst.ONSAddr, "http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet");
 
        // 设置消费者监听器
        ExampleMessageListener messageListener = new ExampleMessageListener();
 
        // 订阅指定Topic下的消息
        // 注意：此处的Group需要和Producer端设置的Group一致，以便ONS服务识别不同的消费者
        Consumer consumer = ONSFactory.createConsumer(properties);
        consumer.subscribe("Your_Topic", "Your_Consumer_Group", messageListener);
        consumer.start();
 
        System.out.println("Consumer Started.");
    }
}

在这个示例中，我们创建了一个简单的消息监听器，用于接收和处理来自阿里云开放消息服务（ONS）的消息。我们首先配置了必要的属性，包括生产者ID、访问密钥和密钥，以及ONS服务的地址。然后，我们创建了一个消费者实例，订阅了特定的Topic和消费者组，并启动了消费者来监听和接收消息。每当有消息到达时，consume方法会被调用，并处理接收到的消息。