关于数据库:java如何使用tldb-MQ

起源：java如何应用tldb MQ

tldb是高性能分布式数据库

• 次要解决分布式服务问题与数据库集群问题
• 基于 tldb，能够用最简洁最快的形式搭建分布式服务零碎

java mq客户端tlmq-j开源地址：https://github.com/donnie4w/tlmq-j

MQ是构建分布式我的项目的一把利剑，tldb mq是一个高性能，易用，易保护，牢靠的MQ服务

tlmq-j 的 mavan依赖配置：

<dependency>        <groupId>io.github.donnie4w</groupId>        <artifactId>tlmq-j</artifactId>        <version>0.0.1</version></dependency>

应用阐明：

1. 先实例操作对象，SimpleClient第一个参数为服务器连贯，第二个参数是mq的用户名明码，用=连贯

   MqClient mc = new SimpleClient("ws://127.0.0.1:5100", "mymq =123");MqClient是对立接口，SimpleClient为tlmq-j实现的繁难实现，实现了tldb mq的协定，反对断线重连，反对wss协定

2. 实现接管订阅信息的handler，用于接管服务器推送的信息

   mc.pubJsonHandler((mb) -> {logger.info(mb.toString());});

3. 调用函数连贯服务器

   mc.connect();

4. 订阅topic，MQ服务器订阅的topic，推送相应的信息

   mc.sub("userinfo")

5. 公布信息. 公布信息即播送信息给所有订阅该topic的节点

   mc.pubJson("userinfo", "this is java pubJson")

其余函数阐明：

1. 指定该连贯接管信息，服务器能够聚合多条信息一起发送，参数示意原传输数据的最大大小，单位M

    mc.mergeOn((byte) 10); 设定服务器压缩原数据大小下限 10M

2. subCancel是勾销该节点订阅的topic

    sc.subCancel("userinfo"); //订阅 topic “userinfo”

3. pullIdSync是拉取指定topic的以后id，也即最大id，tldb mq 每个topic都有惟一id，都会在公布时自增， 用于客户端比拟判断本地是否有信息为接管到或失落数据

    long id = mc.pullIdSync("userinfo");

4. pullJsonSync与pullByteSync作用是拉取topic数据，第一个参数是topic，第二个参数是topic的id值

    JMqBean jmb = mc.pullJsonSync("userinfo", 1); MqBean mb = mc.pullByteSync("userinfo", 1);

5. tldb mq还有其余的接口
   请看《如何应用tldb MQ》有具体的接口阐明

有任何问题或倡议请Email：donnie4w@gmail.com或 http://tlnet.top/contact 发信给我，谢谢！