阿里出击！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 AliyunOnsMessageListenerExample implements MessageListener {
 
    @Override
    public Action consume(Message message, ConsumeContext context) {
        // 处理消息的业务逻辑
        System.out.println("收到消息：" + new String(message.getBody()));
 
        // 返回成功处理的标识
        return Action.CommitMessage;
    }
 
    public static void main(String[] args) {
        Properties properties = new Properties();
        properties.put("AccessKey", "您的AccessKey");
        properties.put("SecretKey", "您的SecretKey");
        properties.put("ONSAddr", "http://onsaddr-international.aliyun.com/rocketmq/nsaddr4client-international");
 
        // 订阅消息
        String consumerId = "请替换成您的consumer ID";
        try {
            // 获取消费者
            com.aliyun.openservices.ons.api.Consumer consumer = ONSFactory.createConsumer(properties);
            // 订阅特定Topic和消费者
            consumer.subscribe(consumerId, "YourTopic", new AliyunOnsMessageListenerExample());
            // 启动消费者
            consumer.start();
            System.out.println("Consumer Started!");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

这个示例代码展示了如何使用阿里云消息服务(ONS)的Java SDK来订阅消息并实现一个简单的消息监听器。在这个例子中，我们创建了一个AliyunOnsMessageListenerExample类实现了MessageListener接口，并实现了consume方法来处理收到的消息。在main方法中，我们配置了必要的认证信息，创建了消费者实例，为特定的Topic订阅了消费者，并启动了消费者来接收消息。