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