Apache-Ignite-2.3.0-中文开发手册

12.平台和协议

12.1.摘要

Ignite为主要的语言和技术，以原生库的形式提供了一套API，包括Java，.NET和C++，还支持包括REST、Memcached以及Redis在内的多种协议。

12.2.REST API

Ignite提供了一个HTTP REST客户端，可以以REST的方式通过HTTP或者HTTPS协议与集群进行通信。REST API可以用于执行不同的操作，比如从/对缓存的读/写，执行任务，获取各种指标等等。

12.2.1.入门

要启用HTTP连接，确保在类路径中包含ignite-rest-http模块，在二进制发行版中，这意味着将libs\optional\ignite-rest-http拷贝到libs\ignite-rest-http中。
不需要显式地进行配置，连接器就会自动启动，然后监听8080端口，可以通过curl检测其是否工作正常。

curl http://localhost:8080/ignite?cmd=version

12.2.2.API参考

• 返回值
• log
• version
• decr
• incr
• cache
• cas
• prepend
• append
• rep
• getrep
• repval
• rmvall
• rmvval
• rmv
• getrmv
• add
• putall
• put
• getall
• get
• conkey
• conkeys
• getput
• putifabs
• getputifabs
• size
• getorcreate
• destcache
• node
• top
• exe
• res
• qryexe
• qryfldexe
• qryfetch
• qrycls
• metadata
• qryscanexe

在内部，Ignite使用Jetty来提供HTTP服务的功能，HTTP REST客户端可以使用ConnectorConfiguration进行配置。

12.2.2.1.返回值

HTTP REST请求返回一个JSON对象，每一个命令都有一个类似的结构，这个对象有如下的结构：

12.2.2.2.log

log命令显示服务器的日志。
URL:

http://host:port/ignite?cmd=log&from=10&to=100&path=/var/log/ignite.log

请求参数

返回值示例

{
  "error": "",
  "response": ["[14:01:56,626][INFO ][test-runner][GridDiscoveryManager] Topology snapshot [ver=1, nodes=1, CPUs=8, heap=1.8GB]"],
  "successStatus": 0
}

12.2.2.3.version

version命令显示当前Ignite的版本。
URL:

http://host:port/ignite?cmd=version

请求参数

返回值示例

{
  "error": "",
  "response": "1.0.0",
  "successStatus": 0
}

12.2.2.4.decr

decr命令减去然后获得给定原子性Long类型的当前值。
URL:

http://host:port/ignite?cmd=decr&cacheName=partionedCache&key=decrKey&init=15&delta=10

请求参数

返回值示例

{
  "affinityNodeId": "e05839d5-6648-43e7-a23b-78d7db9390d5",
  "error": "",
  "response": -42,
  "successStatus": 0
}

12.2.2.5.incr

incr命令增加然后获得给定原子性Long类型的当前值。
URL:

http://host:port/ignite?cmd=incr&cacheName=partionedCache&key=incrKey&init=15&delta=10

请求参数

返回值示例

{
  "affinityNodeId": "e05839d5-6648-43e7-a23b-78d7db9390d5",
  "error": "",
  "response": 42,
  "successStatus": 0
}

12.2.2.6.cache

cache命令可以获得Ignite缓存的指标。
URL:

http://host:port/ignite?cmd=cache&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "",
  "error": "",
  "response": {
    "createTime": 1415179251551,
    "hits": 0,
    "misses": 0,
    "readTime": 1415179251551,
    "reads": 0,
    "writeTime": 1415179252198,
    "writes": 2
  },
  "successStatus": 0
}

"createTime": 1415179251551, "hits": 0, "misses": 0, "readTime":1415179251551, "reads": 0,"writeTime": 1415179252198, "writes": 2
}|

12.2.2.7.cas

cas命令在之前的值等于预期值时会在缓存中存储给定的键值对。
URL:

http://host:port/ignite?cmd=cas&key=casKey&val2=casOldVal&val1=casNewVal&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.8.prepend

prepend命令为给定的键关联的值增加一个前缀。
URL:

http://host:port/ignite?cmd=prepend&key=prependKey&val=prefix_&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.9.append

append命令为给定的键关联的值增加一个后缀。
URL:

http://host:port/ignite?cmd=append&key=appendKey&val=_suffix&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.10.rep

rep命令为给定的键存储一个新值。
URL:

http://host:port/ignite?cmd=rep&key=repKey&val=newValue&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.11.getrep

getrep命令为给定的键存储一个新值,然后返回原值。
URL:

http://host:port/ignite?cmd=getrep&key=repKey&val=newValue&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": oldValue,
  "successStatus": 0
}

12.2.2.12.repval

repval命令在之前的值等于预期值时会替换给定键的值。
URL:

http://host:port/ignite?cmd=repval&key=repKey&val=newValue&val2=oldVal&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.13.rmvall

rmvall命令会从缓存中删除给定键的数据。
URL:

http://host:port/ignite?cmd=rmvall&k1=rmKey1&k2=rmKey2&k3=rmKey3&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.14.rmvval

rmvval命令当当前值等于预期值时在缓存中删除给定键对应的映射。
URL:

http://host:port/ignite?cmd=rmvval&key=rmvKey&val=rmvVal&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.15.rmv

rmv命令在缓存中删除给定键对应的映射。
URL:

http://host:port/ignite?cmd=rmv&key=rmvKey&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.16.getrmv

getrmv命令在缓存中删除给定键的映射,然后返回原值。
URL:

http://host:port/ignite?cmd=getrmv&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": value,
  "successStatus": 0
}

12.2.2.17.add

add命令当缓存中不存在该映射时存储该映射。
URL:

http://host:port/ignite?cmd=add&key=newKey&val=newValue&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.18.putall

putall命令会在缓存中存储给定的键值对。
URL:

http://host:port/ignite?cmd=putall&k1=putKey1&k2=putKey2&k3=putKey3&v1=value1&v2=value2&v3=value3&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.19.put

put命令在缓存中存储该映射。
URL:

http://host:port/ignite?cmd=put&key=newKey&val=newValue&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "1bcbac4b-3517-43ee-98d0-874b103ecf30",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.20.getall

getall命令会从缓存中获取给定键的数据。
URL:

http://host:port/ignite?cmd=getall&k1=getKey1&k2=getKey2&k3=getKey3&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "",
  "error": "",
  "response": {
    "key1": "value1",
    "key2": "value2"
  },
  "successStatus": 0
}

12.2.2.21.get

get命令在缓存中获取给定的键对应的值。
URL:

http://host:port/ignite?cmd=get&key=getKey&cacheName=partionedCache&destId=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "affinityNodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
  "error": "",
  "response": "value",
  "successStatus": 0
}

12.2.2.22.conkey

conkey命令在缓存中检测是否有给定键对应的条目。
URL:

http://host:port/ignite?cmd=conkey&key=getKey&cacheName=partionedCache

请求参数

返回值示例

{
  "affinityNodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.23.conkeys

conkeys命令在缓存中检测是否有给定键对应的条目。
URL:

http://host:port/ignite?cmd=conkeys&k1=getKey1&k2=getKey2&k3=getKey3&cacheName=partionedCache

请求参数

返回值示例

{
  "affinityNodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.24.getput

getput命令在缓存中存储给定的键值对，如果之前存在该映射的话则返回原值。
URL:

http://host:port/ignite?cmd=getput&key=getKey&val=newVal&cacheName=partionedCache

请求参数

返回值示例

{
  "affinityNodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
  "error": "",
  "response": "value",
  "successStatus": 0
}

12.2.2.25.putifabs

putifabs命令只有在缓存中存在该映射的话才会存储给定的键值对。
URL:

http://host:port/ignite?cmd=putifabs&key=getKey&val=newVal&cacheName=partionedCache

请求参数

返回值示例

{
  "affinityNodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
  "error": "",
  "response": true,
  "successStatus": 0
}

12.2.2.26.getputifabs

getputifabs命令只有在缓存中不存在该映射时才会进行存储，否则会返回对应该键的原值。
URL:

http://host:port/ignite?cmd=getputifabs&key=getKey&val=newVal&cacheName=partionedCache

请求参数

返回值示例

{
  "affinityNodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
  "error": "",
  "response": "value",
  "successStatus": 0
}

12.2.2.27.size

size命令返回指定缓存的总条目的数量。
URL:

http://host:port/ignite?cmd=size&cacheName=partionedCache

请求参数

返回值示例

{
  "affinityNodeId": "",
  "error": "",
  "response": 1,
  "successStatus": 0
}

12.2.2.28.getorcreate

getorcreate命令如果不存在的话会创建给定名字的缓存。
URL:

http://host:port/ignite?cmd=getorcreate&cacheName=partionedCache

请求参数

返回值示例

{
  "error": "",
  "response": null,
  "successStatus": 0
}

12.2.2.29.destcache

destcache命令删除给定名字的缓存。
URL:

http://host:port/ignite?cmd=destcache&cacheName=partionedCache

请求参数

返回值示例

{
  "error": "",
  "response": null,
  "successStatus": 0
}

12.2.2.30.node

node命令获取一个节点的信息。
URL:

http://host:port/ignite?cmd=node&attr=true&mtr=true&id=c981d2a1-878b-4c67-96f6-70f93a4cd241

请求参数

返回值示例

{
  "error": "",
  "response": {
    "attributes": null,
    "caches": {},
    "consistentId": "127.0.0.1:47500",
    "defaultCacheMode": "REPLICATED",
    "metrics": null,
    "nodeId": "2d0d6510-6fed-4fa3-b813-20f83ac4a1a9",
    "replicaCount": 128,
    "tcpAddresses": ["127.0.0.1"],
    "tcpHostNames": [""],
    "tcpPort": 11211
  },
  "successStatus": 0
}

12.2.2.31.top

top命令获取一个网络拓扑的信息。
URL:

http://host:port/ignite?cmd=top&attr=true&mtr=true&id=c981d2a1-878b-4c67-96f6-70f93a4cd241

请求参数

返回值示例

{
  "error": "",
  "response": [
    {
      "attributes": {
        ...
      },
      "caches": [
        {
          name: "",
          mode: "PARTITIONED"
        },
        {
          name: "partionedCache",
          mode: "PARTITIONED",
          sqlSchema: "partionedCache"
        }
      ],
      "consistentId": "127.0.0.1:47500",
      "metrics": {
        ...
      },
      "nodeId": "96baebd6-dedc-4a68-84fd-f804ee1ed995",
      "replicaCount": 128,
      "tcpAddresses": ["127.0.0.1"],
      "tcpHostNames": [""],
      "tcpPort": 11211
   },
   {
     "attributes": {
       ...
     },
     "caches": [
       {
         name: "",
         mode: "REPLICATED"
       }
     ],
     "consistentId": "127.0.0.1:47501",
     "metrics": {
       ...
     },
     "nodeId": "2bd7b049-3fa0-4c44-9a6d-b5c7a597ce37",
     "replicaCount": 128,
     "tcpAddresses": ["127.0.0.1"],
     "tcpHostNames": [""],
     "tcpPort": 11212
   }
  ],
  "successStatus": 0
}

12.2.2.32.exe

exe命令在集群中执行给定的任务。
URL:

http://host:port/ignite?cmd=exe&name=taskName&p1=param1&p2=param2&async=true

请求参数

返回值示例

{
  "error": "",
  "response": {
    "error": "",
    "finished": true,
    "id": "~ee2d1688-2605-4613-8a57-6615a8cbcd1b",
    "result": 4
  },
  "successStatus": 0
}

12.2.2.33.res

res命令获取指定任务的计算结果。
URL:

http://host:port/ignite?cmd=res&id=8daab5ea-af83-4d91-99b6-77ed2ca06647

请求参数

返回值示例

{
  "error": "",
  "response": {
    "error": "",
    "finished": true,
    "id": "69ad0c48941-4689aae0-6b0e-4d52-8758-ce8fe26f497d~4689aae0-6b0e-4d52-8758-ce8fe26f497d",
    "result": 4
  },
  "successStatus": 0
}

12.2.2.34.qryexe

qryexe命令在缓存中执行指定的查询。
URL:

http://host:port/ignite?cmd=qryexe&type=Person&pageSize=10&cacheName=Person&arg1=1000&arg2=2000qry=salary+%3E+%3F+and+salary+%3C%3D+%3F

请求参数

返回值示例

{
  "error":"",
  "response":{
    "fieldsMetadata":[],
    "items":[
      {"key":3,"value":{"name":"Jane","id":3,"salary":2000}},
      {"key":0,"value":{"name":"John","id":0,"salary":2000}}],
    "last":true,
    "queryId":0},
  "successStatus":0
}

12.2.2.35.qryfldexe

qryfldexe命令在缓存中执行指定的有字段的查询。
URL:

http://host:port/ignite?cmd=qryfldexe&pageSize=10&cacheName=Person&qry=select+firstName%2C+lastName+from+Person

请求参数

返回值示例

{
  "error":"",
  "response":{
    "fieldsMetadata":[{"fieldName":"FIRSTNAME", "fieldTypeName":"java.lang.String", "schemaName":"person", "typeName":"PERSON"},{"fieldName":"LASTNAME","fieldTypeName":"java.lang.String","schemaName":"person","typeName":"PERSON"}],
    "items":[["Jane","Doe"],["John","Doe"]],
    "last":true,
    "queryId":0
  },
  "successStatus":0}

12.2.2.36.qryfetch

qryfetch命令获取指定查询的下一页数据。
URL:

http://host:port/ignite?cmd=qryfetch&pageSize=10&qryId=5

请求参数

返回值示例

{
  "error":"",
  "response":{
    "fieldsMetadata":[],
    "items":[["Jane","Doe"],["John","Doe"]],
    "last":true,
    "queryId":0
  },
  "successStatus":0}

12.2.2.37.qrycls

qrycls命令关闭查询占用的资源。
URL:

http://host:port/ignite?cmd=qrycls&qryId=5

请求参数

返回值示例

{
  "error":"",
  "response":true,
  "successStatus":0
}

12.2.2.38.metadata

metadata命令返回指定缓存的元数据。
URL:

http://host:port/ignite?cmd=metadata&cacheName=partionedCache

请求参数

返回值示例

{
  "error": "",
  "response": {
    "cacheName": "partionedCache",
    "types": [
      "Person"
    ],
    "keyClasses": {
      "Person": "java.lang.Integer"
    },
    "valClasses": {
      "Person": "org.apache.ignite.Person"
    },
    "fields": {
      "Person": {
        "_KEY": "java.lang.Integer",
        "_VAL": "org.apache.ignite.Person",
        "ID": "java.lang.Integer",
        "FIRSTNAME": "java.lang.String",
        "LASTNAME": "java.lang.String",
        "SALARY": "double"
      }
    },
    "indexes": {
      "Person": [
        {
          "name": "ID_IDX",
          "fields": [
            "id"
          ],
          "descendings": [],
          "unique": false
        },
        {
          "name": "SALARY_IDX",
          "fields": [
            "salary"
          ],
          "descendings": [],
          "unique": false
        }
      ]
    }
  },
  "sessionToken": "",
  "successStatus": 0
}

12.2.2.39.qryscanexe

qryscanexe命令在缓存中执行SQL扫描查询。
URL:

http://host:port/ignite?cmd=qryscanexe&pageSize=10&cacheName=Person&className=org.apache.ignite.schema.Person

请求参数

返回值示例

{
  "error": "",
  "response": {
    "fieldsMetadata": [
      {
        "fieldName": "key",
        "fieldTypeName": "",
        "schemaName": "",
        "typeName": ""
      },
      {
        "fieldName": "value",
        "fieldTypeName": "",
        "schemaName": "",
        "typeName": ""
      }
    ],
    "items": [
      {
        "key": 1,
        "value": {
          "firstName": "Jane",
          "id": 1,
          "lastName": "Doe",
          "salary": 1000
        }
      },
      {
        "key": 3,
        "value": {
          "firstName": "Jane",
          "id": 3,
          "lastName": "Smith",
          "salary": 2000
        }
      }
    ],
    "last": true,
    "queryId": 0
  },
  "successStatus": 0
}

12.2.3.常规配置

12.2.4.Jetty XML配置示例

配置文件的路径需要通过上面描述的ConnectorConfiguration.setJettyPath(String)进行设定。

<?xml version="1.0"?>
<!DOCTYPE Configure PUBLIC "-//Jetty//Configure//EN" "http://www.eclipse.org/jetty/configure.dtd">
<Configure id="Server" class="org.eclipse.jetty.server.Server">
    <Arg name="threadPool">
        <!-- Default queued blocking thread pool -->
        <New class="org.eclipse.jetty.util.thread.QueuedThreadPool">
            <Set name="minThreads">20</Set>
            <Set name="maxThreads">200</Set>
        </New>
    </Arg>
    <New id="httpCfg" class="org.eclipse.jetty.server.HttpConfiguration">
        <Set name="secureScheme">https</Set>
        <Set name="securePort">8443</Set>
        <Set name="sendServerVersion">true</Set>
        <Set name="sendDateHeader">true</Set>
    </New>
    <Call name="addConnector">
        <Arg>
            <New class="org.eclipse.jetty.server.ServerConnector">
                <Arg name="server"><Ref refid="Server"/></Arg>
                <Arg name="factories">
                    <Array type="org.eclipse.jetty.server.ConnectionFactory">
                        <Item>
                            <New class="org.eclipse.jetty.server.HttpConnectionFactory">
                                <Ref refid="httpCfg"/>
                            </New>
                        </Item>
                    </Array>
                </Arg>
                <Set name="host">
                  <SystemProperty name="IGNITE_JETTY_HOST" default="localhost"/>
                </Set>
                <Set name="port">
                  <SystemProperty name="IGNITE_JETTY_PORT" default="8080"/>
                </Set>
                <Set name="idleTimeout">30000</Set>
                <Set name="reuseAddress">true</Set>
            </New>
        </Arg>
    </Call>
    <Set name="handler">
        <New id="Handlers" class="org.eclipse.jetty.server.handler.HandlerCollection">
            <Set name="handlers">
                <Array type="org.eclipse.jetty.server.Handler">
                    <Item>
                        <New id="Contexts" class="org.eclipse.jetty.server.handler.ContextHandlerCollection"/>
                    </Item>
                </Array>
            </Set>
        </New>
    </Set>
    <Set name="stopAtShutdown">false</Set>
</Configure>

12.3.Memcached

Ignite支持Memcached协议，可以通过任何Memcached兼容客户端从Ignite缓存中存储和获取分布化的数据。

当前，Ignite只支持Memcached的二进制协议。

可以通过如下语言的Memcached客户端连接到Ignite：

• PHP
• Java
• Python
• Ruby

12.3.1.PHP

要使用PHP客户端通过Memcached连接到Ignite，首先要下载Ignite，然后：

• 启动配置有缓存的Ignite，比如：

bin/ignite.sh examples/config/example-cache.xml

• 通过二进制协议用Memcached客户端连接到Ignite：

// Create client instance.
$client = new Memcached();
// Set localhost and port (set to correct values).
$client->addServer("localhost", 11211);
// Force client to use binary protocol.
$client->setOption(Memcached::OPT_BINARY_PROTOCOL, true);
// Put entry to cache.
if ($client->add("key", "val"))
    echo "Successfully put entry in cache.\n";
// Check entry value.
echo("Value for 'key': " . $client->get("key") . "\n");

12.3.2.Java

要使用Java客户端通过Memcached连接到Ignite，首先要下载Ignite，然后：

• 启动配置有缓存的Ignite，比如：

bin/ignite.sh examples/config/example-cache.xml

• 通过二进制协议用Memcached客户端连接到Ignite：

MemcachedClient client = null;
try {
    client = new MemcachedClient(new BinaryConnectionFactory(),
            AddrUtil.getAddresses("localhost:11211"));
} catch (IOException e) {
    e.printStackTrace();
}
client.set("key", 0, "val");
System.out.println("Value for 'key': " + client.get("key"));

12.3.3.Python

要使用Python客户端通过Memcached连接到Ignite，首先要下载Ignite，然后：

• 启动配置有缓存的Ignite，比如：

bin/ignite.sh examples/config/example-cache.xml

• 通过二进制协议用Memcached客户端连接到Ignite：

import pylibmc
client = memcache.Client(["127.0.0.1:11211", binary=True])
client.set("key", "val")
print "Value for 'key': %s" % 
client.get("key")

12.3.4.Ruby

要使用Ruby客户端通过Memcached连接到Ignite，首先要下载Ignite，然后：

• 启动配置有缓存的Ignite，比如：

bin/ignite.sh examples/config/example-cache.xml

• 通过二进制协议用Memcached客户端连接到Ignite：

require 'dalli'
options = { :namespace => "app_v1", :compress => true }
client = Dalli::Client.new('localhost:11211', options)
client.set('key', 'value')
value = client.get('key')

12.4.Redis

Ignite实现了对Redis的部分兼容，可以使用任何Redis兼容客户端在缓存中存储以及获取分布化的数据。
Ignite客户端支持如下的命令：
连接

• ECHO
• PING
• QUIT
• SELECT

字符串

• GET
• MGET（限制：对于不存在的键，查询结果中不包含空值）
• SET（限制：没有键过期）
• MSET
• INCR
• DECR
• INCRBY
• DECRBY
• APPEND
• STRLEN
• GETSET
• SETRANGE
• GETRANGE

键

• DEL（限制：返回提交的键的数量）
• EXISTS

服务器

• DBSIZE
• FLUSHDB
• FLUSHALL

集群节点通过监听特定的端口来接收Redis请求，每个Ignite节点默认都会通过监听[host]:11211来接收请求，通过ConnectorConfiguration可以覆写主机和端口：

<bean class="org.apache.ignite.configuration.IgniteConfiguration">
    ...
    <property name="connectorConfiguration">
        <bean class="org.apache.ignite.configuration.ConnectorConfiguration">
        <property name="host" value="localhost"/>
        <property name="port" value="6379"/>
        </bean>
    </property>
</bean>

配置默认缓存
需要配置一个默认的redis-ignite-internal-cache-0缓存，用于默认的Redis数据库，当切换到SELECT命令时也可以用做其他数据库的模板。

可以使用自己喜欢的Redis客户端接入Ignite，下面是是用几种语言的简单示例：

12.4.1.Java

要使用Redis的java客户端接入Ignite，需要先配置并启动一个Ignite集群。
要接入使用6379端口的Ignite，以Jedis为例：

JedisPoolConfig jedisPoolCfg = new JedisPoolConfig();
// your pool configurations.
JedisPool pool = new JedisPool(jedisPoolCfg, "localhost", 6379, 10000);
try (Jedis jedis = pool.getResource()) {
    jedis.set("key1", "1");
    System.out.println("Value for 'key1': " + jedis.get("key1"));
}
pool.destroy();

12.4.2.Python

要使用Redis的Python客户端接入Ignite，需要先配置并启动一个Ignite集群。
要接入使用6379端口的Ignite，以redis-py为例：

>>> import redis
>>> r = redis.StrictRedis(host='localhost', port=6379, db=0)
>>> r.set('k1', 1)
True
>>> r.get('k1')
'1'

12.4.3.PHP

要使用Redis的PHP客户端接入Ignite，需要先配置并启动一个Ignite集群。
要接入使用6379端口的Ignite，以predis为例：

// Load the library.
require 'predis/autoload.php';
Predis\Autoloader::register();
// Connect.
try {
    $redis = new Predis\Client();
    echo ">>> Successfully connected to Redis. \n";
    // Put entry to cache.
    if ($redis->set('k1', '1'))
        echo ">>> Successfully put entry in cache. \n";
    // Check entry value.
    echo(">>> Value for 'k1': " . $redis->get('k1') . "\n");
}
catch (Exception $e) {
    echo "Couldn't connected to Redis";
    echo $e->getMessage();
}