我想使用 Java 和 Cassandra 2.x(在 Jersey 框架上)构建一个 RESTful API。我对这两种技术都不熟悉，所以我想问一下，集成和共享 Cassandra 驱动程序的正确方法是什么。

<强>0。通过 Maven 获取驱动程序

<dependency>
            <groupId>com.datastax.cassandra</groupId>
            <artifactId>cassandra-driver-core</artifactId>
            <version>2.0.3</version>
</dependency>

<强>1。使用 Client 类包装驱动程序的功能:

package com.example.cassandra;

import com.datastax.driver.core.*;

public class Client {

    private Cluster cluster;
    private Session session;

    public Client(String node) {
        connect( node );
    }

    private void connect(String node) {
        cluster = Cluster.builder()
            .addContactPoint(node)
            .build();

        session = cluster.connect();
    }

    public ResultSet execute( String cql3 ) {
        return session.execute( cql3 );
    }

    public void close() {
      cluster.close();
    }

}

<强>2。我在 ContextListener 中使客户端充满并通过上下文属性共享它

package com.example.listener;

import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import com.example.cassandra.Client;

public class ExampleContextListener implements ServletContextListener {

    Client cassandraClient;

    public void contextInitialized(ServletContextEvent servletContextEvent) {
        ServletContext ctx = servletContextEvent.getServletContext();

        cassandraClient = new Client( ctx.getInitParameter( "DBHost" ) );
        ctx.setAttribute( "DB", cassandraClient );
    }

    public void contextDestroyed(ServletContextEvent servletContextEvent) {
        cassandraClient.close();
    }

}

<强>3。现在我从 servlet 的上下文中获取客户端并使用它

Client client =  (Client) context.getAttribute("DB");
client.execute("USE testspace;");

ResultSet rs = client.execute("SELECT * from users;");
for (Row row : rs ) {
    output += row.getString("lname") + "|";
}

这是正确的方法吗(从性能和架构的角度来看)？

完整示例可在:https://github.com/lukaszkujawa/jersey-cassandra

最佳答案

我刚刚开发了你要开发的东西。您写的内容有效，但这不是我最喜欢的方法。我宁愿创建一个单例(因为 1 个 session 对于一个应用程序来说就足够了)。遵循 Joshua Bloch 枚举的单例模式，这就是我所做的

    public enum Cassandra {

        DB;

        private Session session;
        private Cluster cluster;
        private static final Logger LOGGER = LoggerFactory.getLogger(Cassandra.class);

        /**
         * Connect to the cassandra database based on the connection configuration provided.
         * Multiple call to this method will have no effects if a connection is already established
         * @param conf the configuration for the connection
         */
        public void connect(ConnectionCfg conf) {
            if (cluster == null && session == null) {
                cluster = Cluster.builder().withPort(conf.getPort()).withCredentials(conf.getUsername(), conf.getPassword()).addContactPoints(conf.getSeeds()).build();
                session = cluster.connect(conf.getKeyspace());
            }
            Metadata metadata = cluster.getMetadata();
            LOGGER.info("Connected to cluster: " + metadata.getClusterName() + " with partitioner: " + metadata.getPartitioner());
            metadata.getAllHosts().stream().forEach((host) -> {
                LOGGER.info("Cassandra datacenter: " + host.getDatacenter() + " | address: " + host.getAddress() + " | rack: " + host.getRack());
            });
        }

        /**
         * Invalidate and close the session and connection to the cassandra database
         */
        public void shutdown() {
            LOGGER.info("Shutting down the whole cassandra cluster");
            if (null != session) {
                session.close();
            }
            if (null != cluster) {
                cluster.close();
            }
        }

        public Session getSession() {
            if (session == null) {
                throw new IllegalStateException("No connection initialized");
            }
            return session;
        }
}

在上下文监听器中，我调用连接或关闭。 由于新驱动程序中的所有异常都未经检查，我给你的建议是创建你自己的 Jersey ExceptionMapper 映射 DriverException 的实现。还有一件事，考虑使用 PreparedStatements 而不是 Strings，以便 Cassandra 只解析一次查询。在我的应用程序中，我也遵循上述模式进行查询(一个枚举单例，在第一次加载时准备语句，然后公开使用这些语句的方法)。

喂， 卡罗

关于java - 从 Web 应用程序使用 Cassandra 驱动程序的正确方法是什么，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24687991/