当前位置: 首页 > 知识库问答 >
问题:

使用TCP的Ehcache Jgroups复制

方季同
2023-03-14

我试图在Ehcache中使用Jgroups设置一个复制的缓存。我在集群缓存时遇到了问题。我在eclipse中创建了两个项目,每个项目引用不同的ehcache.xml配置文件。

这两个配置文件都是相同的,并且都给出了BEOLW。

<?xml version="1.0"?>
<cacheManagerPeerProviderFactory
    class="net.sf.ehcache.distribution.jgroups.JGroupsCacheManagerPeerProviderFactory"
    properties="connect=TCP(bind_port=7800):
    TCPPING(initial_hosts=localhost[7800],localhost[7801];port_range=10;timeout=3000;
    num_initial_members=3):
    VERIFY_SUSPECT(timeout=1500):
    pbcast.NAKACK(retransmit_timeout=3000):
    pbcast.GMS(join_timeout=50000;print_local_addr=true)"
propertySeparator="::" />

 <cache name="sampleCache"
        maxElementsInMemory="1000000"
        eternal="true"
        overflowToDisk="false">
        <cacheEventListenerFactory
        class="net.sf.ehcache.distribution.jgroups.JGroupsCacheReplicatorFactory"
        properties="replicateAsynchronously=true"/>
</cache>
63511 [main] DEBUG org.jgroups.protocols.pbcast.NAKACK  - 
[SBSPBWSVM110-42986 setDigest()]
existing digest:  []
new digest:       SBSPBWSVM110-42986: [0 (0)]
resulting digest: SBSPBWSVM110-42986: [0 (0)]
63511 [main] DEBUG org.jgroups.protocols.pbcast.GMS  - SBSPBWSVM110-42986: installing view [SBSPBWSVM110-42986|0] (1) [SBSPBWSVM110-42986]
63543 [main] DEBUG org.jgroups.protocols.pbcast.GMS  - SBSPBWSVM110-42986: created cluster (first member). My view is [SBSPBWSVM110-42986|0], impl is org.jgroups.protocols.pbcast.CoordGmsImpl
Jan 09, 2015 11:49:51 AM net.sf.ehcache.distribution.jgroups.JGroupsCacheManagerPeerProvider init

INFO:JGroups Replication started for 'EH_CACHE'. JChannel: local_addr=SBSPBWSVM110-42986
cluster_name=EH_CACHE
my_view=[SBSPBWSVM110-42986|0] (1) [SBSPBWSVM110-42986]
state=CONNECTED
discard_own_messages=true
state_transfer_supported=false
63451 [main] DEBUG org.jgroups.protocols.pbcast.NAKACK  - 
[SBSPBWSVM110-20554 setDigest()]
existing digest:  []
new digest:       SBSPBWSVM110-20554: [0 (0)]
resulting digest: SBSPBWSVM110-20554: [0 (0)]
63451 [main] DEBUG org.jgroups.protocols.pbcast.GMS  - SBSPBWSVM110-20554: installing view [SBSPBWSVM110-20554|0] (1) [SBSPBWSVM110-20554]
63452 [main] DEBUG org.jgroups.protocols.pbcast.GMS  - SBSPBWSVM110-20554: created cluster (first member). My view is [SBSPBWSVM110-20554|0], impl is org.jgroups.protocols.pbcast.CoordGmsImpl
Jan 09, 2015 11:49:51 AM net.sf.ehcache.distribution.jgroups.JGroupsCacheManagerPeerProvider init

INFO: JGroups Replication started for 'EH_CACHE'. JChannel: local_addr=SBSPBWSVM110-20554
cluster_name=EH_CACHE
my_view=[SBSPBWSVM110-20554|0] (1) [SBSPBWSVM110-20554]
state=CONNECTED
discard_own_messages=true
state_transfer_supported=false

我无法在这里找到问题。是我的配置错误吗??请帮助我解决这个问题…

共有1个答案

阎安邦
2023-03-14

您使用的配置很奇怪:它遗漏了一些协议。ehcache不能引用JGroups配置文件,例如udp.xml吗?另外,在TCP中设置bind_addr或使用-djgroups.bind_addr=1.2.3.4,其中1.2.3.4是网络接口。然后,在tcpping.initial_hosts中,需要列出具有上面使用的绑定地址的所有成员,例如1.2.3.4[7800]、5.6.7.8[7800]等。

 类似资料:
  • 注:本节未经校验,如有问题欢迎提issue 贯穿本节的代码片段假定以下imports: import akka.actor.{ Actor, ActorRef, Props } import akka.io.{ IO, Tcp } import akka.util.ByteString import java.net.InetSocketAddress 所有的Akka I/O API 都通过管理

  • 在Akka中有没有什么方法可以像在Erlang中一样用{packet,4}来实现包帧?数据包如下所示:

  • 我想建立一个节点集群。前面有负载平衡器的js服务(由于某些原因,不能有粘性会话)。 让我们想象一下,我有两个节点,客户机(例如,浏览器,使用socket.io)发送wss://请求,第一个节点从LB获取请求,然后它发送回客户机的“HTTP/1.1 101 Web套接字协议握手”响应。 > 在使用插座的情况下。在WebSocket连接建立以提高性能之前,它可能仍然会回退并通过http发送长轮询。这些

  • 我试图使用Spring Integration创建一个iso8385 TCP服务器。典型的情况如下: 客户端连接到服务器并保存ISO8385消息 服务器处理消息 服务器制定响应并关闭连接 我希望跟踪每个新的TCP连接,并为其创建一个标识符,以便将每个处理与连接的客户端相关联。但我不知道怎么做。这个想法是: 将ISO8385转换为java类的tcp入站适配器 将处理消息的服务激活器 将java类转换

  • 大多数人似乎都通过UDP使用NAT穿孔,但在我的例子中,我需要使用TCP(这是事实,在有人问“为什么不使用UDP?”之前)我找不到任何示例代码或至少一个适当的教程。我能找到的都是理论上的附属物,但没有使用套接字或TCPClients(我更喜欢套接字)。 有人能给我链接一些示例代码吗?我可以用这些示例代码连接两个NAT后的客户端,或者用示例代码链接到完整的教程?我知道在.NET中很难实现这个目标(我

  • 我正在考虑将Netty用于我的第一层美国银行算法交易项目。然而,我找不到任何简单乒乓TCP测试的性能数字: 客户端向服务器发送64字节的消息 服务器接收消息并发送回客户端 客户端计算往返的延迟时间 我知道EPoll forLinux是最快的NIO实现。 我的问题是:Netty在4Ghz处理器上往返发送64字节消息的平均时间、最短时间和最长时间是多少?我将首先测试本地主机/环回。