阿里云MQ消息队列详细使用说明文档 |
一.新建maven项目,引入配置如下附件中内容,如果没有使用maven插件,可以直接导入jar包(阿里云MQ使用相关jar包.rar)。
二.新建两个测试类,一个是生产者类,一个是消费者类,代码内容可以从阿里云官方网站上copy,也可以参考附件中的代码。
在代码中涉及到几方面内容:密钥、生产者id、消费者id、主题库topic,下面说一下如何在阿里云平台上获取这些内容:
- 在浏览器输入https://www.aliyun.com/,登录控制台(用淘宝帐号就行),然后点击右上方菜单“管理控制台” 进入控制台管理页面
- 选择左边菜单中的消息队列菜单:注意画标识的地方
- 点击发布Topic按钮,新建topic,这里的topic是全网唯一的,新建如下:
- 点击“申请发布”链接:这时会新建一个生产者id,建好之后返回列表:
这里的示例代码就是生产者类的样本代码。
- 点击topic中的“申请订阅”链接:这时会新建一个消费者id,列表如下:
如果找不到topic列表,可以点击左边的发布订阅管理,展开菜单,找到Topic管理菜单,如下图:
这里的示例代码就是消费者类的样本代码。
- 最后新建密钥:图二中的标识4区域,点击AccessKeys按钮,点击创建Access Key按钮:创建完毕,这里的key可以建多个。
三.以上步骤中已经获取到了我们需要的Topic、生产者id、消费者id、密钥和示例代码,这里说下运行环境:jdk6以上版本(个别1.6环境下会报一个平台版本低的异常:Your platform does not provide complete low-level API for accessing direct buffers reliably,如果报了这个错同时运行出现异常,建议更换1.7的jdk),运行生产者代码(前提是把步骤二中的获取的各种id和密钥放到代码中相应的位置),如果打印出类似以下的信息说明生产者方发送消息成功。
SendResult{messageId=’0A91883700001F90000009413B513402′}
运行消费者代码:如果打印出消息体内容,说明消费者端接收消息成功。
本文原创,转载请注明来源地址:http://www.itxm.net/a/bianchengyuyan/2017/0623/1456.html 谢谢!
转载请注明来源网站:blog.ytso.com谢谢!
原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/14599.html