1介绍之前我们在文章《K8ssandra入门-详细记录在Linux上部署K8ssandra到Kubernetes》中成功在Ubuntu上安装了K8ssandra,下面我们来看看如何访问Cassandra。Stargate是K8ssandra的一个组件,提供了多种数据访问方式。对应端口如下:8080:GraphQL接口8081:RESTAuth8082:REST接口9042:CQL服务我们使用最常用的9042端口,其他请参考官方文档。2三种访问方式先暴露服务,再找到对应的端口:$kubectlexposedeploymentk8ssandra-dc1-stargate--type=NodePort--name=stargate-out$kubectlgetsvcstargate-out2.1cqlshcommandinstallclqsh命令:$pipinstallcqlsh连接数据库:cqlsh-uk8ssandra-superuser-pYMEbXcPCW9xxxxxxx127.0.0.130703然后进行数据操作:CREATEKEYSPACEpkslowWITHreplication={'class':'SimpleStrategy','replication_factor':1};使用pkslow;CREATETABLE用户(用户名文本主键、密码文本、电子邮件文本);INSERTINTOusers(username,password,email)values('larry','larry123','larry@pkslow.com');INSERTINTO用户(用户名,密码,邮箱)值('admin','123456','admin@pkslow.com');INSERTINTO用户(用户名,密码,邮箱)值('carol','123456','carol@pkslow.com');INSERTINTOusers(username,password,email)values('david','123456','david@pkslow.com');写入数据后,我们查看一下:2.2用IDEA连接配置数据库,选择Cassandra,连接信息如下:然后可以查看相关数据,如下:2.3通过Java程序访问导入依赖如下:<依赖项>org.springframework。dataspring-data-cassandra3.2.5准备实体类:packagecom.pkslow.springboot.cassandra.entity;importorg.springframework.data.annotation.Id;importorg.springframework.data.cassandra.core.mapping.Table;@Table(value="users")publicclassUser{@IdprivateStringusername;私有字符串密码;privateStringemail;}Repository类:packagecom.pkslow.springboot.cassandra.repository;importcom.pkslow.springboot.cassandra.entity.User;importorg.springframework.data.cassandra.repository.CassandraRepository;importorg.springframework.stereotype.Repository;@RepositorypublicinterfaceUserRepositoryextendsCassandraRepository{}同时需要在配置类中添加:@EnableCassandraRepositories(basePackages="com.pkslow.springboot.cassandra.repository")配置一次数据库连接属性:server.port=8080spring.data.cassandra.contact-points=8.134.124.38:30703spring.data.cassandra.username=k8ssandra-superuserspring.data.cassandra.password=YMEbXcPCW9xrfxxxxxspring.data.cassandra.local-datacenter=dc1spring.data.cassandra.keyspace-name=pkslow这样基本就可以启动程序了,访问测试如下:3摘要代码请查看:https://github.com/LarryDpk/p...