首页 文章

Cassandra Datastax驱动程序 - 连接池

提问于
浏览
10

我正在尝试理解Datastax Cassandra Driver中的连接池,所以我可以在我的Web服务中更好地使用它 .

我有1.0版本的文档 . 它说:

Java驱动程序异步使用连接,因此可以在同一连接上同时提交多个请求 .

他们通过连接了解什么?连接到群集时,我们有:构建器,群集和会话 . 其中哪一个是连接?

例如,有这个参数:

maxSimultaneousRequestsPerConnection - 与主机的所有连接上的同时请求数,然后创建更多连接 .

因此,在连接池的情况下,这些连接会自动创建(这是我所期望的) . 但究竟是什么联系?集群对象? Session ?

我正在尝试决定在我的网络服务中保持“静态”的内容 . 目前,我决定保持Builder静态,因此对于每次调用,我都会创建一个新的Cluster和一个新的Session . 这个可以吗?如果群集是连接,那么它应该没问题 . 但是吗?现在, Logger 说,每次通话:

2013:12:06 12:05:50 DEBUG群集:742 - 使用联系点启动新群集2013:12:06 12:05:50 DEBUG ControlConnection:216 - [控制连接]刷新节点列表和令牌映射2013:12 :06 12:05:50 DEBUG ControlConnection:219 - [控制连接]刷新架构2013:12:06 12:05:50 DEBUG ControlConnection:147 - [控制连接]已成功连接到...

那么,它每次都连接到集群?这不是我想要的,我想重用连接 .

那么,连接实际上是Session?如果是这种情况,我应该保持群集静态,而不是构建器 .

我应该调用什么方法,以确保尽可能重用连接?

3 回答

  • 9

    你是对的,连接实际上在Session中,Session是你应该给DAO写入Cassandra的对象 .

    只要您使用相同的Session对象,就应该重用连接(您可以将Session视为连接池) .

    编辑(2017/4/10):我在@William Price之后对这个答案进行了预测 . 请注意,这个答案是4岁,而Cassandra在此期间已经改变了一点!

  • 2

    accepted answer(在撰写本文时)正在给出正确的建议:

    只要您使用相同的Session对象,您[将]重用连接 .

    但是,有些部分最初过于简单 . 我希望以下内容能够深入了解每种对象类型的范围及其各自的用途 .

    Builder≠Cluster≠Session≠Connection≠Statement

    Cluster.Builder用于配置和创建群集

    群集代表整个Cassandra戒指

    环由多个节点(主机)组成,环可以支持一个或多个键空间 . 您可以在Cluster对象中查询cluster-(ring)-level属性 .

    我也把它看作代表响铃的调用应用程序的对象 . 您将应用程序的需求(例如加密,压缩等)传达给构建器,但是此对象首先实现/与实际C *环通信 . 如果您的应用程序为不同的用户/目的使用多个身份验证凭据,则即使它们连接到同一个环,您也可能拥有不同的Cluster对象 .

    会话本身不是连接,但它管理它们

    会话可能需要与环中的所有节点通信,除了在仅包含一(1)个节点的环的特殊情况之外,这不能通过单个TCP连接来完成 . 会话管理connection pool,该池通常至少有一个连接用于环中的每个节点 . This is why you should re-use Session objects as much as possible. An application does not directly manage or access connections.

    从Cluster对象访问会话;它通常是"bound"一次到单个键空间,它成为从该会话执行的语句的默认键空间 . 语句可以使用完全限定的表名(例如 keyspacename.tablename )来访问其他键空间中的表,因此不需要使用多个会话来跨键空间访问数据 . 使用多个会话与同一个环进行通信会增加所需的TCP连接总数 .

    语句在会话中执行

    语句可以是prepared,每个语句都可以改变数据或查询它(在某些情况下,两者都是) . 最快,最有效的语句最多需要与之通信一个节点和来自拓扑感知群集的会话应仅在单个TCP连接上联系该节点(或其中一个对等节点) . 效率最低的语句必须触及所有副本(大多数节点),但这将由环本身上的协调器节点处理,因此即使对于这些语句,Session也只使用来自应用程序的单个连接 .

    此外,驱动程序使用的Cassandra二进制协议的版本2和3使用连接上的多路复用 . 因此,虽然单个语句至少需要一个TCP连接,但该单个连接可能同时为多达128或32k个异步请求提供服务,具体取决于协议版本(分别) .

  • 7

    只是社区的更新 . 您可以通过以下方式设置连接池

    private static Cluster cluster;
    
    cluster.getConfiguration().getPoolingOptions().setMaxConnectionsPerHost(HostDistance.LOCAL,100);
    

相关问题