AsyncGraphClientImpl 实例在多线程场景下的情况

sixiang · 2021 年2 月 26 日 02:04

nebula 版本：1.2.0
部署方式（分布式）：
硬件信息
- 磁盘（SSD）
- CPU、内存信息 40core 192GB
问题的具体描述
AsyncGraphClientImpl java 客户端是否可以单例模式在多线程场景下使用，是线程安全的么？因为我这边注意到一步客户端的实现内部是提交给一个线程的线程池去执行。

liuyu85cn · 2021 年2 月 26 日 02:16

是线程安全的

nicole · 2021 年2 月 26 日 02:28

如何多线程使用可以看下这个issue

github.com/vesoft-inc/nebula-java

Why using ThreadLocal<GraphService.Client> in GraphClientImpl?

已打开 08:54AM - 22 Oct 20 UTC

已关闭 01:37AM - 27 Nov 20 UTC

RaulGuo

In the GraphClientImpl.java, I noticed that the "client" field is used to execut…e the real query is using the following way: ``` public class GraphClientImpl extends AbstractClient implements GraphClient { // the real thrift client is wrapped in a ThreadLocal private ThreadLocal<GraphService.Client> client = new ThreadLocal<>(); @Override public int doConnect(List<HostAndPort> addresses) throws TException { GraphService.Client thriftClient = new GraphService.Client(protocol); client.set(thriftClient); } ``` This works well when the GraphClientImpl object is used within the same thread that create it, but if I create a new Thread, and use this GraphClientImpl object within the new thread, I cannot get the GraphService.client using the ThreadLocal. ``` GraphClient graphClient = new GraphClientImpl(addresses); // this works well graphClient.executeQuery(gql); // this doesn't work because in new thread, graphClient cannot get the real thriftClient using ThreadLocal new Thread(() -> { graphClient.executeQuery(gql); }).start(); ``` I have two questions about this: 1. Why using ThreadLocal to wrap the GraphService.Client? Is it to achieve multi-thread safe? If we don't use ThreadLocal, where there will be trouble? 2. Is there a better way to do this? In this way, the thread that want to use GraphClientImpl object must be the thread that create this object, it is very inconvenient and easy to make mistakes. Thanks for any help.

sixiang · 2021 年2 月 26 日 02:39

sixiang · 2021 年2 月 26 日 02:52

那这样的话是否就不需要实现一个AsyncGraphClientImpl 的连接池了呢？只需要保证该client在接受并发请求时不做space切换？

nicole · 2021 年2 月 26 日 03:26

因为在多线程中同时使用同一个连接是不支持的，所以需要在子线程内进行连接，不同的连接独立执行后续的操作。

sixiang · 2021 年2 月 26 日 03:45

如此我想监控AsyncGraphClientImpl 内部的线程池及任务队列情况该如何扩展呢

sixiang · 2021 年2 月 26 日 03:57

继承AbstractClient 重新实现即可是么

sixiang · 2021 年2 月 26 日 07:51

AsyncGraphClientImpl 也不可以么？这似乎跟liuyu85cn
的说法不太一样呢

sixiang · 2021 年2 月 26 日 07:52

AsyncGraphClientImpl 使用时也需要每个线程中重复 connect ？

nicole · 2021 年2 月 26 日 08:57

AsyncGraphClientImpl是不需要重复connect的，上面需要在子线程内connect的是GraphClientImpl，也可以作为伪线程安全的客户端来使用。不冲突呀

sixiang · 2021 年3 月 2 日 12:56

AsyncGraphClientImpl 使用一段时间后提示 session xxx has expired，请问可以怎么解决呢

darionyaphet · 2021 年3 月 4 日 08:12

设一下 session 超时时间

sixiang · 2021 年3 月 4 日 08:13

可以设置会话不过期么，值为多少呢