全部产品
云市场

使用开源 Spring Java SDK 访问阿里云 MQ

更新时间:2019-09-13 22:00:01

开源 SDK 连接阿里云 MQ,需要重新修改部分配置信息,使用方式和默认配置保持兼容。

前提条件

添加 Maven 依赖

请在 pom.xml 文件中添加以下依赖:

  1. <dependency>
  2. <groupId>org.apache.rocketmq</groupId>
  3. <artifactId>rocketmq-spring-boot-starter</artifactId>
  4. <version>${RELEASE.VERSION}</version>
  5. </dependency>

设置参数

参考开源 Java 设置,使用 Spring 连接上云需要同样设置部分 ACL 参数和接入点。打开 application.properties 文件,修改参数即可。

生产者示例代码

  1. //控制台上获取的接入点信息
  2. rocketmq.name-server=http://XXXX.mq-internet-access.mq-internet.aliyuncs.com:80
  3. //控制台上申请的 GID 或者 PID
  4. rocketmq.producer.group=GID_XXXX
  5. //用户的 AccessKeyId 和 AccessKeySecret,控制台上可以获取
  6. rocketmq.producer.access-key=AK
  7. rocketmq.producer.secret-key=SK

消费者示例代码

  1. //控制台上获取的接入点信息
  2. rocketmq.name-server=http://XXXX.mq-internet-access.mq-internet.aliyuncs.com:80
  3. //控制台申请的 Topic 资源
  4. rocketmq.topic=TOPIC
  5. //控制台上申请的 GID 或者 PID
  6. rocketmq.consumer.group=GID_XXXX
  7. //用户的 AccessKeyId 和 AccessKeySecret,控制台上可以获取
  8. rocketmq.consumer.access-key=AK
  9. rocketmq.consumer.secret-key=SK

更多信息

Spring 的使用方法和示例代码详情,请参见 Spring Demo