doc
This commit is contained in:
@@ -13,6 +13,15 @@
|
|||||||
* 提供类似JPA功能,包含数据缓存自动同步、分表分库与简洁的数据层操作接口
|
* 提供类似JPA功能,包含数据缓存自动同步、分表分库与简洁的数据层操作接口
|
||||||
* 提供了MQ消息消费与生产简洁化API
|
* 提供了MQ消息消费与生产简洁化API
|
||||||
|
|
||||||
|
## 版本
|
||||||
|
```xml
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.redkale</groupId>
|
||||||
|
<artifactId>redkale</artifactId>
|
||||||
|
<version>2.8.0</version>
|
||||||
|
</dependency>
|
||||||
|
```
|
||||||
|
|
||||||
## 开发文档
|
## 开发文档
|
||||||
* [快速入门](docs/quick-start.md)
|
* [快速入门](docs/quick-start.md)
|
||||||
* [Service组件](docs/service.md)
|
* [Service组件](docs/service.md)
|
||||||
|
|||||||
@@ -150,7 +150,7 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
|
|||||||
for (ClientFuture respFuture : respFutures) {
|
for (ClientFuture respFuture : respFutures) {
|
||||||
offerRespFuture(respFuture);
|
offerRespFuture(respFuture);
|
||||||
}
|
}
|
||||||
sendRequestInLocking(respFutures);
|
sendRequestToChannel(respFutures);
|
||||||
}
|
}
|
||||||
} finally {
|
} finally {
|
||||||
writeLock.unlock();
|
writeLock.unlock();
|
||||||
@@ -158,10 +158,6 @@ public abstract class ClientConnection<R extends ClientRequest, P extends Client
|
|||||||
return respFutures;
|
return respFutures;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void sendRequestInLocking(ClientFuture... respFutures) {
|
|
||||||
sendRequestToChannel(respFutures);
|
|
||||||
}
|
|
||||||
|
|
||||||
protected final void sendRequestToChannel(ClientFuture... respFutures) {
|
protected final void sendRequestToChannel(ClientFuture... respFutures) {
|
||||||
// 发送请求数据包
|
// 发送请求数据包
|
||||||
writeArray.clear();
|
writeArray.clear();
|
||||||
|
|||||||
Reference in New Issue
Block a user