folkmq 发行版 - Gitee.com

2024-03-01 14:58

最后提交信息为： 1.2.4

2024-02-29 17:47

## 一、更新说明

### (1) for Java
* 添加 rpc 异常传导机制

### (2) for JavaScript

* 完成 js 客户端开发（兼容：浏览器，uni-app，node.js）

### (3) 新功能演示

* 事务消息 for js：

```java
//准备（1.取名字；2.添加事务回查）
const client = await FolkMQ.createClient("folkmq:ws://127.0.0.1:18602")
    .nameAs("demoapp") //一般用当前应用名
    .connect();

//用于服务端发起的事务回查
client.transactionCheckback(m => {
  //极端特殊的情况下，客户端未完成事务确认。由服务端发起补尝确认
  if("1" == m.getAttr("orderId")) {
      //一般这里，需要查询数据库之类的
      m.acknowledge(true);
  }
});
    
//发送事务消息    
const tran = client.newTransaction();

try {
    client.publish("demo", FolkMQ.newMessage("demo1").attr("orderId","1").transaction(tran));
    client.publish("demo", FolkMQ.newMessage("demo2").attr("orderId","1").transaction(tran));
    client.publish("demo", FolkMQ.newMessage("demo3").attr("orderId","1").transaction(tran));
    client.publish("demo", FolkMQ.newMessage("demo4").attr("orderId","1").transaction(tran));

tran.commit();
} catch (err) {
    tran.rollback();
}
```

* 发送与监听模式模式 - rpc for js：

```java
//客户端1
const client1 = await FolkMQ.createClient("folkmq:ws://127.0.0.1:18602")
                        .nameAs("demoapp1")
                        .connect();

//客户端1监听
const router = FolkMQ.newRouter(m => m.getTag()).doOn("/hello", req => {
    req.respone(SocketD.newEntity("me to!"));
});
client1.listen(router.consume.bind(router));

//客户端2
const client2 = await FolkMQ.createClient("folkmq:ws://127.0.0.1:18602")
                        .nameAs("demoapp2")
                        .connect();

//客户端2发送
const resp = client2.send(FolkMQ.newMessage("helloworld!").tag("hello"), "demoapp1").await();
console.log(resp.dataAsString());
```

## 二、兼容说明

* 本次更新，向下兼容。
* 新增的功能功能（事务消息，发送与监听模式模式，消息属性），需要新版服务端和客户端支持。

最后提交信息为： 1.2.3

v1.2.2

cdb4485

2024-02-27 14:07

FolkMQ v1.2.2

### 更新说明（优化 rpc 接口体验；强化 trans 概念）

* 调整 response 拆分为：transactionCheckback 和 listen
* 调整 request 改为 send
* 添加 transactionCheckback 用于响应服务端的事务回查
* 添加 listen 和 send 配套接口
* 添加 后台图标
* 完善 许可证本地处理机制
* sokcet.d 升为 2.4.4

新功能示例（事务消息）：

```java
//准备（1.取名字；2.添加事务回查）
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demoapp") //一般用当前应用名
    .connect();

//用于服务端发起的事务回查
client.transactionCheckback(m->{
  if (m.isTransaction()) {
      //极端特殊的情况下，客户端未完成事务确认。由服务端发起补尝确认
      if("1".equals(m.getAttr("orderId"))) {
          //一般这里，需要查询数据库之类的
          m.acknowledge(true);
      }
  }
});
    
//发送事务消息    
MqTransaction tran = client.newTransaction();

try {
    client.publish("demo", new MqMessage("demo1").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo2").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo3").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo4").attr("orderId","1").transaction(tran));

tran.commit();
} catch (Throwable e) {
    tran.rollback();
}
```

新功能示例（发送与监听模式模式 - rpc）：

```java
//客户端1
MqClient client1 = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                        .nameAs("demoapp1")
                        .connect();

//客户端1监听
client1.listen(new MqRouter(m -> m.getTag()).doOn("hello", request -> {
    System.out.println(request);
    request.acknowledge(new StringEntity("me to!"));
}));

//客户端2
MqClient client2 = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                        .nameAs("demoapp2")
                        .connect();

//客户端2发送
Reply reply = client2.send(new MqMessage("helloworld!").tag("hello"), "demoapp1").await();
System.out.println(reply.dataAsString());
```

### 兼容说明

* 本次更新，向下兼容。
* 新增的功能功能（事务消息，发送与监听模式模式，消息属性），需要新版服务端和客户端支持。

最后提交信息为： 1.2.2

v1.2.1

4322afb

2024-02-23 16:05

FolkMQ v1.2.1

本次版本发布，增加了"事务消息"、"消息属性"、"请求与响应模式（rpc）" 的支持。

### 更新说明

* 添加 协议版本的握手传递
* 添加 消息事务支持（即二段式提交），支持反向事务确认
* 添加 请求响应模式支持（即 rpc 模式）
* 添加 消息用户属性支持
* 优化 内存占用与快照大小
* 优化 安全停止延时改为4秒
* 优化 客户端相关参数校验
* 优化 客户端的心跳间隔为6秒
* 优化 停止打印信息
* sokcet.d 升为 2.4.3

新功能示例（事务消息）：

```java
//准备（1.取名字；2.添加响应实现）
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demoapp") //一般用当前应用名
    .connect();

//用于响应服务端发起的反向确认
client.response(m->{
  if (m.isTransaction()) {
      //极端特殊的情况下，客户端未完成事务确认。由服务端发起补尝确认
      if("1".equals(m.getAttr("orderId"))) {
          //一般这里，需要查询数据库之类的
          m.acknowledge(true);
      }
  }
});
    
//发送事务消息    
MqTransaction tran = client.newTransaction();

try {
    client.publish("demo", new MqMessage("demo1").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo2").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo3").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo4").attr("orderId","1").transaction(tran));

tran.commit();
} catch (Throwable e) {
    tran.rollback();
}
```

新功能示例（请求响应模式）：

```java
//客户端2
MqClient client1 = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demo-app1") 
    .connect();

//要支持 rpc 响应，要添加响应实现（MqResponseRouter 带了主体路由功能）
client1.response(new MqResponseRouter().doOn("test.hello", m -> {
    m.acknowledge(true, new StringEntity(m.getSender() +  ": me to! rev: " + m.getContent()));
}));

//客户端2
MqClient client2 = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demo-app2")
    .connect();

//发起请求并等响应，同步模式
Reply reply = client2.request("demo-app1", "test.hello", new MqMessage("hello")).await();
print(reply.dataAsString());
```

### 兼容说明

* 本次更新，向下兼容。
* 新增的功能功能（事务消息，RPC模式，消息属性），需要新版服务端和客户端支持。

最后提交信息为： 1.2.1

v1.2.0

bac0f32

2024-02-23 15:17

FolkMQ v1.2.0

### 更新说明

* 添加 协议版本的握手传递
* 添加 消息事务支持（即二段式提交），支持反向事务确认
* 添加 请求响应模式支持（即 rpc 模式）
* 添加 消息用户属性支持
* 优化 内存占用与快照大小
* 优化 安全停止延时改为4秒
* 优化 客户端相关参数校验
* 优化 客户端的心跳间隔为6秒
* 优化 停止打印信息
* sokcet.d 升为 2.4.3

新功能示例（事务消息）：

```java
//准备（1.取名字；2.添加响应实现）
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demoapp") //一般用当前应用名
    .connect();

//用于响应服务端发起的反向确认
client.response(m->{
  if (m.isTransaction()) {
      //极端特殊的情况下，客户端未完成事务确认。由服务端发起补尝确认
      if("1".equals(m.getAttr("orderId"))) {
          //一般这里，需要查询数据库之类的
          m.acknowledge(true);
      }
  }
});
    
//发送事务消息    
MqTransaction tran = client.newTransaction();

try {
    client.publish("demo", new MqMessage("demo1").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo2").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo3").attr("orderId","1").transaction(tran));
    client.publish("demo", new MqMessage("demo4").attr("orderId","1").transaction(tran));

tran.commit();
} catch (Throwable e) {
    tran.rollback();
}
```

新功能示例（请求响应模式）：

```java
//客户端2
MqClient client1 = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demo-app1") 
    .connect();

//要支持 rpc 响应，要添加响应实现（MqResponseRouter 带了主体路由功能）
client1.response(new MqResponseRouter().doOn("test.hello", m -> {
    m.acknowledge(true, new StringEntity(m.getSender() +  ": me to! rev: " + m.getContent()));
}));

//客户端2
MqClient client2 = FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .nameAs("demo-app2")
    .connect();

//发起请求并等响应，同步模式
Reply reply = client2.request("demo-app1", "test.hello", new MqMessage("hello")).await();
print(reply.dataAsString());
```

### 兼容说明

* 本次更新，向下兼容。
* 新增的功能功能（事务消息，RPC模式，消息属性），需要新版服务端和客户端支持。

最后提交信息为： 1.2.0