慕沐8596765
379886946
我也是这样认为的,还有,我按照他的方法去配置A、B、C节点,跟着程序步骤如下:
1、生产程序生产消息推送到B或者C节点。
2、消费程序就单独监听A节点。
结果:消费程序不能消费到任何消息,A节点在这里做不到消费的负载均衡
(不知道是不是我配置是否有问题,但我已经看了好多遍视频再次重新进行配置了)
qq_紫風_2
win10自带虚拟机 Hyper-V
qq_酒哩_0
配置错了吧
会飞的狼3012
慕粉3964261
哥们 你的问题解决了吗 我遇到了相同的问题
2019-04-19 17:39:08,070 | INFO | activemq-cluster bridge to Unknown stopped | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ BrokerService[activemq-cluster] Task-280
2019-04-19 17:39:08,072 | INFO | activemq-cluster bridge to Unknown stopped | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ BrokerService[activemq-cluster] Task-279
2019-04-19 17:39:08,074 | INFO | error with pending local brokerInfo on: vm://activemq-cluster#484 | org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ BrokerService[activemq-cluster] Task-279
org.apache.activemq.transport.TransportDisposedIOException: peer (vm://activemq-cluster#485) stopped.
at org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:233)[activemq-broker-5.15.2.jar:5.15.2]
at org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)[activemq-client-5.15.2.jar:5.15.2]
at org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1193)[activemq-broker-5.15.2.jar:5.15.2]
at org.apache.activemq.broker.TransportConnection$4.run(TransportConnection.java:1159)[activemq-broker-5.15.2.jar:5.15.2]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_172]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_172]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_172]
2019-04-19 17:39:08,076 | WARN | Could not start network bridge between: vm://activemq-cluster and: tcp://192.168.0.231:61617 due to: Connection refused (Connection refused) | org.apache.activemq.network.DiscoveryNetworkConnector | ActiveMQ Task-62
tan1210
老师演示的集群同一个时刻只会有一个节点提供服务,如果A挂掉,那么其它节点会补上的。因为其它节点获取到了kahadb的锁。
qq_云端_8
我找到了,把上节课启动的关了就好了。。。。
甲壳虫爱上了夏天
你报错信息是什么,是不是说连接不上BC?如果是的,那很正常,因为BC还没有启动.
Mr_DCH
新版本的activemq只支持1.8
coldfire0
B和C不会主动导流给A,而是通过消费者客户端去选择了一个节点,可能是A也可能是B或C。以此来降低B或C的负载。