Redis 替代品SSDB Java客户端

╰半橙微兮° 2022-08-07 13:38 154阅读 0赞

SSDB支持 Redis 网络协议, 所以你可以用 Redis 的客户端来连接 SSDB 服务器. 但是, 使用 SSDB 客户端是最高效的方式。所有的 SSDB 客户端 API 都是支持二进制数据的, 二进制数据即是字符串,字符串就是二进制数据。SSDB 源码仓库中, 内置了许多语言的客户端, 这些便是所谓的[官方客户端][Link 1]。

关于java客户端，有如下几种：

**1.官方客户端**

项目地址：[https://github.com/ssdb/javassdb][https_github.com_ssdb_javassdb]

文档说明：[http://ssdb.io/docs/java/][http_ssdb.io_docs_java]

实例代码参考：[Demo.java][]

**2.ssdb4j**

SSDB的Java驱动,实现了连接池,主从。连接池使用commons-pool。

项目地址：[https://github.com/ideawu/ssdb][https_github.com_ideawu_ssdb]

maven  dependency:

实例代码参考：[SimpleClientTest.java][]  
3.**另一个ssdbj**

SSDBJ是一款支持SSDB NoSQL数据库集群的驱动。  
功能：   
1、ssdb数据库连接池   
2、支持多个SSDB数据库的master-slave集群   
3、支持集群内部的master和slave的负载均衡，负载均衡暂时支持4中方式（Random round\_robin round\_robin\_weight random\_weight）   
4、实现了读写分离   
5、支持集群内slave获取not\_found的情况下从master再次直接获取   
6、支持同步未完成时slave读取error的情况下，从master尝试或者重复在slave中尝试。尝试次数可以再配置文件中修改。   
具体参考 src/test/resource/ssdbj.xml  
ssdbj提供了3中使用方式：  
1、直接手动创建连接，可以参考src/test/java/SSDBJTest.java   
2、使用单库连接池，可以参考 src/test/java/SSDBPoolTest.java   
3、使用集群模式，可以参考src/test/java/SSDBClusterTest.java   
集群模式的配置文件可以参考src/test/resource/ssdbj.xml

项目地址：[http://git.oschina.net/jbakwd/ssdbj][http_git.oschina.net_jbakwd_ssdbj]

下面以jbakwd的ssdbj为例。需要下载源码添加到本地maven仓库中。

<dependency>
    			<groupId>com.lovver</groupId>
    			<artifactId>ssdbj</artifactId>
    			<version>0.0.1</version>
    		</dependency>

集群配置：ssdbj.xml

<?xml version="1.0" encoding="UTF-8"?>
    <ssdbj>
    	
    	<ssdb_node id="ssdb_db1" master="true" host="192.168.36.54"
    		port="8888" user="" password="" loginTimeout="3" tcpKeepAlive="true"
    		protocolName="ssdb" maxTotal="200" maxIdle="10" minIdle="5"
    		testWhileIdle="true" />
    	<ssdb_node id="ssdb_db2" master="true" host="192.168.36.189"
    		port="8888" user="" password="" loginTimeout="3" tcpKeepAlive="true"
    		protocolName="ssdb" maxTotal="200" maxIdle="10" minIdle="5"
    		testWhileIdle="true" />
    	
    	<clusters>
    		<cluster id="ssdb_cluster" notfound_master_retry="true"
    			error_retry_times="3" error_master_retry="true" retry_interval="500"
    			balance="random_weight">
    			
    			<ssdb_node weight="1" rwMode="rw">ssdb_db1</ssdb_node>
    			<ssdb_node weight="2" rwMode="rw">ssdb_db2</ssdb_node>
    		</cluster>
    	</clusters>
    </ssdbj>

测试代码：SSDBClusterTest.java

package cn.slimsmart.redis.demo.ssdb;
    
    import com.lovver.ssdbj.SSDBJ;
    import com.lovver.ssdbj.core.BaseResultSet;
    import com.lovver.ssdbj.core.SSDBCmd;
    
    @SuppressWarnings("unchecked")
    public class SSDBClusterTest {
    	public static void main(String[] args) throws Exception {
            //解析ssdbj.xml，查询ssdb_cluster，找到一个实例执行get key命令
    		//SSDBCmd 支持ssdb命令
    		//executeUpdate 添加更新
    		BaseResultSet<byte[]> rs= SSDBJ.execute("ssdb_cluster",SSDBCmd.GET,"key");
    		System.out.println(rs.getStatus());
            System.out.println(new String(rs.getResult()));
            
            if(SSDBJ.executeUpdate("ssdb_cluster",SSDBCmd.SET,"key","value22")){
            	rs= SSDBJ.execute("ssdb_cluster",SSDBCmd.GET,"key");
            	System.out.println(rs.getStatus());
                System.out.println(new String(rs.getResult()));
            }else{
            	System.out.println("executeUpdate fail.");
            }
    	}
    }

[Link 1]: http://ssdb.io/docs/zh_cn/clients.html
[https_github.com_ssdb_javassdb]: https://github.com/ssdb/javassdb
[http_ssdb.io_docs_java]: http://ssdb.io/docs/java/
[Demo.java]: https://github.com/ssdb/javassdb/blob/master/Demo.java
[https_github.com_ideawu_ssdb]: https://github.com/ideawu/ssdb
[SimpleClientTest.java]: https://github.com/nutzam/ssdb4j/blob/master/src/test/java/org/nutz/ssdb4j/impl/SimpleClientTest.java
[http_git.oschina.net_jbakwd_ssdbj]: http://git.oschina.net/jbakwd/ssdbj