分布式缓存服务 DCS
分布式缓存服务 DCS
- 最新动态
- 功能总览
- 服务公告
- 产品介绍
- 计费说明
- 快速入门
- 用户指南
- 最佳实践
- API参考
- SDK参考
-
常见问题
- 实例类型/版本
- 实例特性
- 安全性
-
客户端和网络连接
- DCS实例支持公网访问吗?
- Redis连接失败问题排查和解决
- DCS实例是否支持跨VPC访问?
- Redis公网访问所需弹性IP是否收费?
- Redis连接时报错:“(error) NOAUTH Authentication required”。
- 客户Http的Server端关闭导致Redis访问失败
- 客户端出现概率性超时错误
- 使用Jedis连接池报错如何处理?
- 如何使用Redis-desktop-manager访问Redis实例?
- 使用SpringCloud时出现ERR Unsupported CONFIG subcommand怎么办?
- 客户端无法使用域名连接DCS缓存实例时如何处理?
- 本地环境是否可以连接缓存实例?
- 使用Redis实例的发布订阅(pubsub)有哪些注意事项?
- Redis 3.0实例公网开关被关闭是什么原因?
- 使用短连接访问Redis出现“Cannot assign requested address”错误
- 连接池选择及Jedis连接池参数配置建议
- 如何解决Lettuce 6.x版本客户端使用DCS实例兼容性问题?
- 应该选择域名还是IP地址连接Redis实例?
- 主备实例的只读地址是连接到主节点还是备节点?
-
Redis使用
- 是否支持CPU架构的变更?
- 实例是否支持变更可用区
- Redis实例能否修改VPC和子网?
- 实例是否支持自定义或修改端口?
- 实例是否支持修改访问地址?
- 实例无法删除是什么原因?
- 集群实例启动时间过长是什么原因?
- 使用redis_exporter出错怎么办?
- 什么是预留内存,如何配置预留内存?
- 创建的缓存实例为什么可使用内存比实例规格少一些?
- Redis 3.0 Proxy集群不支持redisson分布式锁的原因
- DCS Redis有没有后台管理软件?
- DCS缓存实例的数据被删除后,能否找回?
- 为什么实例实际可用内存比申请规格小而且已使用内存不为0?
- 如何查看Redis内存占用量
- Cluster集群实例容量和性能未达到瓶颈,但某个分片容量或性能已过载是什么原因?
- 访问Redis报OOM错误提示
- 不同编程语言如何使用Cluster集群客户端
- 使用Cluster的Redis集群时建议配置合理的超时时间
- 读取redis数据报超时错误
- hashtag的原理、规则及用法示例
- Redis key丢失是什么原因
- 重启实例后缓存数据会保留吗?
- 如何确认实例是单DB还是多DB
- Proxy集群开启多DB的使用限制及操作方式
- 如何创建多DB的Proxy集群实例?
- 扩容缩容与实例升级
-
数据备份/导出/迁移
- DCS实例是否兼容低版本Redis迁移到高版本
- 不同类型的操作系统间进行数据传递和操作,需要注意什么?
- 源Redis使用了多DB,能否迁移数据到集群实例?
- 源Redis迁移到集群实例中有哪些限制和注意事项?
- 在线迁移需要注意哪些?
- 在线迁移能否做到完全不中断业务?
- 在线迁移实例源端报“Disconnecting timedout slave”和“overcoming of output buffer limits”
- 如何导出Redis实例数据?
- 使用Rump工具迁移数据,命令执行后无报错,但Redis容量无变化
- 是否支持控制台导出RDB格式的Redis备份文件?
- 缓存实例备份文件如何存放?备份文件的数量是否有限制?
- Redis在线数据迁移是迁移整个实例数据么?
- AOF文件在什么情况下会被重写
- Redis迁移失败有哪些常见原因?
- 一个数据迁移能迁移到多个目标实例么?
- 怎么放通SYNC和PSYNC命令?
- 迁移或导入备份数据时,相同的Key会被覆盖吗?
- Cluster集群实例使用内置key且跨slot的Lua脚本时迁移失败
- 迁移故障处理
- 数据迁移失败问题排查
- Memcached如何迁移?
- 是否支持Memcached和Redis之间实例数据的迁移?
- 大Key/热Key分析/过期Key扫描
- Redis命令
- 监控告警
- 主备倒换
- 创建实例和权限
- Memcached使用
- 故障排除
- 视频帮助
- 文档下载
- 通用参考
本文导读
链接复制成功!
Spymemcached客户端连接Memcached(Java)
介绍使用同一VPC内弹性云服务器ECS上的Java客户端连接Memcached实例的方法。
前提条件
- 已成功申请Memcached实例,且状态为“运行中”。
- 已创建弹性云服务器,并已安装好客户端。创建弹性云服务器的方法,请参见《弹性云服务器用户指南》。
说明:
您创建的弹性云服务器必须与Memcached实例属于同一个VPC,并配置相同的安全组,以确保弹性云服务器与缓存实例的网络是连通的。
- 如果弹性云服务器与Memcached实例不在相同VPC中,可以通过建立VPC对等连接方式连通网络,具体请参考常见问题:缓存实例是否支持跨VPC访问?
- 如果弹性云服务器与Memcached实例配置了不同的安全组,可以通过设置安全组规则连通网络,具体请参考常见问题:如何选择和配置安全组?
- 您的弹性云服务器已安装好Java JDK和常用的IDE(如Eclipse)。
- 已获取spymemcached-x.y.z.jar依赖包。
说明:
其中x.y.z为依赖包的版本号,建议获取最新版本。
Spymemcached客户端连接Memcached
- 登录分布式缓存服务管理控制台。
- 在管理控制台左上角单击
,选择实例所在的区域。
- 单击左侧菜单栏的“缓存管理”,进入缓存实例信息页面。
- 单击需要使用的其中一个Memcached实例的名称,进入该Memcached实例的基本信息页面。查看并获取该Memcached实例的IP地址/域名和端口。
- 将已获取的spymemcached-x.y.z.jar依赖包上传到已创建的弹性云服务器。
- 登录弹性云服务器。
- 在Eclipse中创建一个Java工程,并将spymemcached-x.y.z.jar依赖包导入,工程名可自定义。
- 新建一个ConnectMemcached1类,将如下Java代码复制到类中并修改代码。
- 密码模式代码示例
其中ip or domain name:port需要修改为4获取的Memcached实例IP地址/域名和端口。userName和password需要修改为Memcached实例的用户名和密码。
//java 连接加密的Memcached代码 import java.io.IOException; import java.util.concurrent.ExecutionException; import net.spy.memcached.AddrUtil; import net.spy.memcached.ConnectionFactoryBuilder; import net.spy.memcached.ConnectionFactoryBuilder.Protocol; import net.spy.memcached.MemcachedClient; import net.spy.memcached.auth.AuthDescriptor; import net.spy.memcached.auth.PlainCallbackHandler; import net.spy.memcached.internal.OperationFuture; public class ConnectMemcached1 { public static void main(String[] args) { final String connectionaddress = "ip or domain name:port"; final String username = "userName";//用户名 final String password = "password";//密码 MemcachedClient client = null; try { AuthDescriptor authDescriptor = new AuthDescriptor(new String[] {"PLAIN"}, new PlainCallbackHandler(username, password)); client = new MemcachedClient( new ConnectionFactoryBuilder().setProtocol(Protocol.BINARY) .setAuthDescriptor(authDescriptor) .build(), AddrUtil.getAddresses(connectionaddress)); String key = "memcached";//向Memcached中存一个key为"memcached"的数据 String value = "Hello World";//value为Hello World int expireTime = 5; // 过期时间,单位s; 从写入时刻开始计时,超过expireTime s后,该数据过期失效,无法再读出; doExcute(client, key, value, expireTime);//执行操作 } catch (IOException e) { e.printStackTrace(); } } /** *向Memcached写数据方法 */ private static void doExcute(MemcachedClient client, String key, String value, int expireTime) { try { OperationFuture<Boolean> future = client.set(key, expireTime, value); future.get();// spymemcached set()是异步的,future.get() 等待cache.set()操作结束,也可以不等待,用户根据自己需求选择; System.out.println("Set操作成功"); System.out.println("Get操作:" + client.get(key)); Thread.sleep(6000);//等待6000毫秒,即6秒,该数据将会过期失效,无法再读出 System.out.println("6秒后再执行Get操作:" + client.get(key)); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } if (client != null) { client.shutdown(); } } }
- 免密模式代码示例
其中ip or domain name:port需要修改为4获取的Memcached实例IP地址/域名和端口。
//java 连接免密的Memcached代码 import java.io.IOException; import java.util.concurrent.ExecutionException; import net.spy.memcached.AddrUtil; import net.spy.memcached.BinaryConnectionFactory; import net.spy.memcached.MemcachedClient; import net.spy.memcached.internal.OperationFuture; public class ConnectMemcached { public static void main(String[] args) { final String connectionaddress = "ip or domain name:port"; MemcachedClient client = null; try { client = new MemcachedClient(new BinaryConnectionFactory(), AddrUtil.getAddresses(connectionaddress)); String key = "memcached";//向Memcached中存一个key为"memcached"的数据 String value = "Hello World";//value为Hello World int expireTime = 5; // 过期时间,单位s; 从写入时刻开始计时,超过 expireTime s后,该数据过期失效,无法再读出; doExcute(client, key, value, expireTime);//执行操作 } catch (IOException e) { e.printStackTrace(); } } /** *向Memcached写数据方法 */ private static void doExcute(MemcachedClient client, String key, String value, int expireTime) { try { OperationFuture<Boolean> future = client.set(key, expireTime, value); future.get();// spymemcached set()是异步的,future.get() 等待cache.set()操作结束,也可以不等待,用户根据自己需求选择; System.out.println("Set操作成功"); System.out.println("Get操作:" + client.get(key)); Thread.sleep(6000);//等待6000毫秒,即6秒,该数据将会过期失效,无法再读出 System.out.println("6秒后再执行Get操作:" + client.get(key)); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } if (client != null) { client.shutdown(); } } }
- 密码模式代码示例
- 运行main方法,在Eclipse下的Console窗口可以看到如下结果。
Set操作成功 Get操作:Hello World 6秒后再执行Get操作:null
父主题: 使用客户端连接Memcached