开源中国 2018 年度最后一场技术盛会邀你来约~错过就要等明年啦!点此立即预约

朽之丶 / spring-boot-starter-natsJava

Watch 2 Star 3 Fork 2
加入码云
与超过 300 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
暂无描述 展开 收起

取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README.md

使用方式

1、获取代码

git clone https://github.com/ChinaSilence/spring-boot-starter-nats.git

2、安装到本地 Maven 仓库

mvn clean install

3、在项目中添加依赖

<!-- Nats 消息中间件 -->
<dependency>
    <groupId>com.anoyi</groupId>
    <artifactId>spring-boot-starter-nats</artifactId>
    <version>1.0-RELEASE</version>
</dependency>

4、配置 Nats 相关参数

# 默认 nats://127.0.0.1
spring:
  nats:
    urls:
      - nats://192.168.99.102:30000
      - nats://192.168.99.102:30001
      - nats://192.168.99.102:30002

5、发布订阅消息

@Autowired
private nats.client.Nats nats;

...

// 订阅消息
public void subscribe() {
	nats.subscribe("some.nats.subject", new MessageHandler() {
	@Override
		public void onMessage(Message message) {
			System.out.println("Received: " + message);
		}
	});
}

// 发布消息
public void send() {
	nats.subscribe("some.nats.subject", "message content");
}

项目点评 ( 0 )

你可以在登录后,发表评论

搜索帮助