我有一组Membase主机,还有一组在不同盒子上运行的moxi进程,都配置为与该集群通信。
我的客户端正在使用spymemcached,我正在尝试配置一个MemcachedClient,使其知道所有可用的moxi进程。这样,如果其中一个进程死亡,我希望spymemcached使用另一个moxi并继续向集群发送数据。
理想情况下,所有这些都应该在不丢失队列信息的情况下完成。
我正在尝试使用两个moxi进程进行操作,但无法实现所需功能。
我已经查看了http://groups.google.com/group/spymemcached/browse_thread/thread/d33ca15c0a928d37#和http://groups.google.com/group/spymemcached/browse_thread/thread/f7cc37fc509b70a6/cbb967e824a0ab04?hl=en&lnk=gst&q=redistribute#cbb967e824a0ab04,但没有找到答案。
请问在spymemcached中是否可以实现?如果可以,应该如何配置?
我正在尝试不同的ConnectionFactoryBuilder配置。
我的客户端正在使用spymemcached,我正在尝试配置一个MemcachedClient,使其知道所有可用的moxi进程。这样,如果其中一个进程死亡,我希望spymemcached使用另一个moxi并继续向集群发送数据。
理想情况下,所有这些都应该在不丢失队列信息的情况下完成。
我正在尝试使用两个moxi进程进行操作,但无法实现所需功能。
我已经查看了http://groups.google.com/group/spymemcached/browse_thread/thread/d33ca15c0a928d37#和http://groups.google.com/group/spymemcached/browse_thread/thread/f7cc37fc509b70a6/cbb967e824a0ab04?hl=en&lnk=gst&q=redistribute#cbb967e824a0ab04,但没有找到答案。
请问在spymemcached中是否可以实现?如果可以,应该如何配置?
我正在尝试不同的ConnectionFactoryBuilder配置。
ConnectionFactoryBuilder builder = new ConnectionFactoryBuilder();
builder.setFailureMode(FailureMode.Redistribute);
builder.setProtocol(Protocol.BINARY);
builder.setLocatorType(Locator.CONSISTENT);
builder.setMaxReconnectDelay(1);
builder.setTimeoutExceptionThreshold(2);
ConnectionFactory cf = builder.build();