java客戶端提交數據到memcached方法memcached+java+client我的總結

時間 2019-11-13

標籤 java 客戶端提交數據 memcached 方法 memcached+java+client client 我的總結欄目 Java 简体版

原文原文鏈接

終於把nginx+memcached+tomcat集羣windows下佈置完成，可是遇到java客戶端提交數據到memcached的問題，上網看了好多人的帖子，發現了3種方法 html

1. 三種API比較
1) memcached client for java java

較早推出的memcached JAVA客戶端API，應用普遍，運行比較穩定。 nginx

2) spymemcached git

A simple, asynchronous, single-threaded memcached client written in java. 支持異步，單線程的memcached客戶端，用到了java1.5版本的concurrent和nio，存取速度會高於前者，可是穩定性很差，測試中常報timeOut等相關異常。 github

3) xmemcached 算法

XMemcached 一樣是基於java nio的客戶端，java nio相比於傳統阻塞io模型來講，有效率高（特別在高併發下）和資源耗費相對較少的優勢。傳統阻塞IO爲了提升效率，須要建立必定數量的鏈接造成鏈接池，而nio僅須要一個鏈接便可（固然,nio也是能夠作池化處理），相對來講減小了線程建立和切換的開銷，這一點在高併發下特別明顯。所以 XMemcached與Spymemcached在性能都很是優秀，在某些方面（存儲的數據比較小的狀況下）Xmemcached比 Spymemcached的表現更爲優秀，具體能夠看這個Java Memcached Clients Benchmark。 windows

2. 建議 api

因爲memcached client for java發佈了新版本，性能上有所提升，而且運行穩定，因此建議使用memcached client for java。緩存

XMemcached 也使用得比較普遍，並且有較詳細的中文API文檔，具備以下特色：高性能、支持完整的協議、支持客戶端分佈、容許設置節點權重、動態增刪節點、支持 JMX、與Spring框架和Hibernate-memcached的集成、客戶端鏈接池、可擴展性好等。 tomcat

我使用的是建議方法memcached client for java，

Memcached-Java-Client官網jar包的下載地址：

https://github.com/gwhalin/Memcached-Java-Client/downloads

Memcached-Java-Client的說明文檔：

https://github.com/gwhalin/Memcached-Java-Client

具體實現步驟爲：

1.將jar包引入項目中，我引入了4個commons-pool-1.5.6.jar,java_memcached-release_2.6.2.jar,slf4j-api-1.6.1.jar,slf4j-simple-1.6.1.jar

2.寫測試代碼：

import java.util.Date;

import com.danga.MemCached.MemCachedClient;
import com.danga.MemCached.SockIOPool;

public class MemCached {
   // 建立全局的惟一實例
   protected static MemCachedClient mcc = new MemCachedClient();

   protected static MemCached memCached = new MemCached();

   // 設置與緩存服務器的鏈接池
   static {
       // 服務器列表和其權重，我的memcached地址和端口號
       String[] servers = { "192.168.88.137:11211" };
       Integer[] weights = { 3 };

       // 獲取socke鏈接池的實例對象
       SockIOPool pool = SockIOPool.getInstance();

       // 設置服務器信息
       pool.setServers(servers);
       pool.setWeights(weights);

       // 設置初始鏈接數、最小和最大鏈接數以及最大處理時間
       pool.setInitConn(5);
       pool.setMinConn(5);
       pool.setMaxConn(250);
       pool.setMaxIdle(1000 * 60 * 60 * 6);

       // 設置主線程的睡眠時間
       pool.setMaintSleep(30);

       // 設置TCP的參數，鏈接超時等
       pool.setNagle(false);
       pool.setSocketTO(3000);
       pool.setSocketConnectTO(0);

       // 初始化鏈接池
       pool.initialize();
   }

   /**
   * 保護型構造方法，不容許實例化！
   *
   */
   protected MemCached() {

   }

   /**
   * 獲取惟一實例.
   *
   * @return
   */
   public static MemCached getInstance() {
       return memCached;
   }

   /**
   * 添加一個指定的值到緩存中.
   *
   * @param key
   * @param value
   * @return
   */
   public boolean add(String key, Object value) {
       return mcc.add(key, value);
   }

   public boolean add(String key, Object value, Date expiry) {
       return mcc.add(key, value, expiry);
   }

   /**
   * 替換一個指定的值到緩存中.
   *
   * @param key
   * @param value
   * @return
   */
   public boolean replace(String key, Object value) {
       return mcc.replace(key, value);
   }

   public boolean replace(String key, Object value, Date expiry) {
       return mcc.replace(key, value, expiry);
   }

   /**
   * 刪除一個指定的值到緩存中.
   *
   * @param key
   * @param value
   * @return
   */
   public boolean delete(String key) {
       return mcc.delete(key);
   }

   /**
   * 根據指定的關鍵字獲取對象.
   *
   * @param key
   * @return
   */
   public Object get(String key) {
       return mcc.get(key);
   }

   public static void main(String[] args) {
       MemCached cache = MemCached.getInstance();
       // cache.add("zf", 18);
       // cache.replace("zf", 19);
       cache.delete("zf");
       System.out.println("zf get value : " + cache.get("zf"));
   }
}

3.測試階段

1）取消cache.add("zf",18)註釋，將cache.replace("zf", 19);和cache.delete("zf");註釋掉，增長zf到memcached中

2）將cache.add("zf",18);cache.replace("zf", 19);和cache.delete("zf");註釋，輸出結果爲剛纔添加的內容，表示該值已經存入memcached中

3) 將cache.delete("zf");取消註釋，再運行，控制檯輸出 zf get value : null，該值已刪除

其餘測試方法：

使用telnet命令語句查看：

1）cmd中輸入telnet 192.168.88.137 11211(本身memcached地址及端口號)

2）輸入命令stats，查看 STAT curr_items 數量，增長、修改、刪除此數量隨之變化

具體memcached輸入stats命令解釋以下：（轉載：http://www.cnblogs.com/suger/archive/2011/09/06/2168319.html）

STAT pid 1552

STAT uptime 3792

STAT time 1262517674