简介
结合上一文，安装部署，go测试例子之后，这次应用到springboot上，使用github封装的用例，
https://github.com/wanlinus/nats-spring.git
案例
1、application-nats.yml
spring:
nats:
natsUrls:
- nats://192.168.2.246:4222
2、java junit测试
import com.alibaba.fastjson.JSON;
import io.nats.client.Connection;
import io.nats.client.Message;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest
@EnableNats
public class ConsoleApiTest {
@Autowired
private Connection connection;
@Subscribe("data")
public void sub(Message message) {
log.info("<<<=== subject={}, data={}", message.getSubject(), new String(message.getData()));
}
@Test
public void pub() {
log.info(connection.getConnectedUrl());
connection.publish("data", "data测试数据".getBytes(StandardCharsets.UTF_8));
try {
connection.flush(Duration.ZERO);
} catch (Exception e) {
e.printStackTrace();
}
try {
Message data = connection.request("data", "data request测试数据".getBytes(StandardCharsets.UTF_8), Duration.ofSeconds(1));
log.info("subject={}, data={}, replyTo={}", data.getSubject(), new String(data.getData()), data.getReplyTo());
log.info(JSON.toJSONString(data));
} catch (InterruptedException e) {
e.printStackTrace();
}
// while (true);
}
}
3、测试结果：
17:19:00.501 [main] INFO c.m.c.c.a.ConsoleApiTest - [message,34] - nats://192.168.2.246:4222
17:19:00.524 [nats:3] INFO c.m.c.c.a.ConsoleApiTest - [message,29] - <<<===subject=data, data=data测试数据
17:19:00.528 [nats:3] INFO c.m.c.c.a.ConsoleApiTest - [message,29] - <<<===subject=data, data=data request测试数据
完成。
go(reply)、java(request)
如果要看到java request返回的内容，开启上一文go nats安装使用 四、请求-回复go测试代码 中的 reply.go测试。
reply.go
package main
import (
"encoding/json"
"github.com/nats-io/nats.go"
"log"
"runtime"
)
func main() {
nc, err := nats.Connect("192.168.2.246:4222")
if err != nil {
log.Fatal("connect error")
}
nc.Subscribe("data", func(m *nats.Msg) {
result, _ := json.Marshal(m)
log.Println("<<<=== ", string(m.Data), "\r\nm=", string(result))
//time.Sleep(5 * time.Second)
pubstr := "reply.go Publish content."
log.Println("===>>> ", pubstr, ", replyTo=", m.Reply)
nc.Publish(m.Reply, []byte(pubstr))
})
runtime.Goexit()
}
运行：
go run reply.go
