有了用Java定义的Apache路由，我可以这样做
from("stream:in?promptMessage=Enter something: ")
.loadBalance()
.to("uria", "urib")
而且它的工作原理就像一只小木瓜。
使用Spring上下文文件尝试这样做是行不通的：
<c:camelContext id="defaultContext">
<c:route id="defaultRoute">
<c:from uri="
浏览 3提问于2013-10-18得票数 1
回答已采纳
我有三台机器。一个(loadbalance.lan)用作负载均衡器，另两个(172.16.30.5和172.16.30.6)是tomcat的服务器。tomcat的主页正在监听端口8080。
我在浏览器中输入loadbalance.lan/tomcat，我可以看到一个tomcat内容(默认的tomcat页面)，问题是页面没有正确显示。这里没有图像，当我点击任何链接时，它会显示404没有找到错误。假设我想访问tomcat网站上的一个子页面。Tomcat网站地址: 172.16.30.5:8080现在我可以选择，我们可以选择“状态”链接，它将我重定向到: 172.16.30.5:8080/manag
浏览 2提问于2013-11-11得票数 1
我正在使用camel无弹簧应用程序，它在http协议中工作得很好。如何使' to‘作为https。
我的camel-config.xml
<routes xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="servlet:///service?matchOnUriPrefix=true"/>
<loadBalance>
<failover>
<exception&
浏览 0提问于2013-12-03得票数 0
回答已采纳
1回答
我有三台for服务器，其中两台运行apache，一台运行haproxy以实现负载平衡。
现在我需要在我的cms上传照片，我如何确保某个URL会进入某个服务器?我的意思是，一个服务器需要是主服务器，第二个服务器是从服务器
或者还有另一种解决方案？
另外，如果人们正在使用像contact-us这样的表单，我如何才能使user这个数据库是相同的？
浏览 1提问于2015-12-06得票数 0
我想整理出SOAP标头的一些节点，以便在apache camel中执行粘性负载平衡。为此，我使用xpath，我的xpath表达式如下所示：
.loadBalance().sticky(xpath("substring(string(/*[local-name()='Envelope']/*[local-name()='Header']/*[local-name()='ReplyTo']/*[local-name()='ReferenceParameters']/*[local-name()='ServiceGrou
浏览 1提问于2012-09-12得票数 0
我们在我们的Pulsar星团中观察到了以下警告。我们应该关心它吗？
18:37:37.165 [pulsar-modular-load-manager-29-1]
WARN org.apache.pulsar.brok er.loadbalance.BundleSplitStrategy -
Could not split namespace bundle pulsareval/0x56000000_0x56800000
because namespace pulsareval has too many bundles: 512
浏览 0提问于2019-08-01得票数 1
我正在一个JBoss Fuse实例中重构一些apache遗留代码，我遇到了一些代码，我不知道它的目的是什么。
<when condition>
<loadBalance id="someVar">
<failover roundRobin="true" maximumFailoverAttempts="3" />
<to uri="fabric:FABRICENDPOINT" />
</loadBala
浏览 2提问于2015-06-15得票数 2
回答已采纳
我正在使用具有以下路由配置的apache camel故障转移组件：
<route id="jettyRouter" errorHandlerRef="defaultErrorHandler">
<from uri="jetty:http://{{Jetty.entryPoint.host}}?matchOnUriPrefix=true"/>
<setExchangePattern pattern="InOut"/>
<loadBalance>
浏览 1提问于2017-11-20得票数 1
1回答
jdbc负载平衡问题
、、、、
我们使用jdbc负载平衡，比如“jdbc:mysql:loadbalance://.”和apache具有最大的300个连接。在执行了一些操作之后，我通过"SHOW PROCESSLIST“查看Mysql中的进程，向我展示了很多连接。在正常行为中，每次都是3-4次连接。有人遇到过这个问题吗？
浏览 3提问于2013-07-23得票数 0
回答已采纳
2回答
我们使用Spring Cloud Gateway JavaDsl作为我们的接口网关。对于代理，我们有多个微服务运行在不同的ip上:端口作为目标的。我想知道我们是否可以配置多个目标来创建云网关代理，类似于apache camel负载均衡器eip。
camel.apache.org/manual/latest/loadBalance-eip.html
我们正在寻找类似于netflix/apache-camel的spring云网关的软件负载均衡，而不是另一个专用的LB。
浏览 6提问于2019-11-28得票数 2
我为Hazelcast (使用kryo)为我的特定Java类实现了一个StreamSerializer。在大多数情况下，这似乎工作得很好，除非我想在具有这种类型的字段的IExecutorService上执行一个可调用的。然后我得到了例外：
com.hazelcast.nio.serialization.HazelcastSerializationException: java.io.NotSerializableException: com.flir.its.flux.infrastructure.loadbalance.hazelcast.HazelcastLoadBalance
a
浏览 3提问于2014-06-16得票数 0
回答已采纳
节点v4.2.3和猫鼬诉4.3.6
我必须遍历一个大型(>10k文档)集合，并处理每个文档。
在阅读有关如何处理这种迭代的文档时，我偶然发现了QueryStream，我认为它可以解决我所有的问题。
function progress(total, t, current) {
process.stdout.clearLine(); // clear current text
process.stdout.write(Math.round(t / total * 100) + '% ' + t + ' / ' + total + '
浏览 2提问于2016-01-21得票数 2
回答已采纳
1回答
它们是服务器上的多个服务，我希望使用我在文档中介绍过的负载平衡endpoint.For。我已经明确了我的概念，但在实际的代理服务中如何实现它是有点混乱的。我创建了一个负载平衡端点，如下所示：
<endpoint xmlns="http://ws.apache.org/ns/synapse" name="TestAddressEndpoint">
<session type="http">
<sessionTimeout>0</sessionTimeout>
</sess
浏览 1提问于2014-10-21得票数 0
我正在使用apache 2.12.2为http请求构建一个负载均衡器。为此，我使用camel-servlet、camel-http组件，我的路由定义如下：
<from uri="servlet:///my/path?matchOnUriPrefix=true" />
<loadBalance inheritErrorHandler="false">
<failover roundRobin="true" maximumFailoverAttempts="2">
<e
浏览 2提问于2013-12-17得票数 2
回答已采纳
下面是我在oozie中的sqoop命令。 <action name="sqoop_test" retry-max="${maxretry}" retry-interval="${retryinterval}">
<sqoop xmlns="uri:oozie:sqoop-action:0.2">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</
浏览 13提问于2019-06-18得票数 0
我使用LINQ从DB加载了一个浮点数组。即使我成功地加载了数组，我也不能创建DataGridView来显示该数组。
以下是我的代码
float[] balances = client.LoadBalance(id);
// LoadBalance() give me an array of floats of customer who has the specified id
dataBalance.DataSource = balances;
我尝试了以下方法，但它们都没有帮助
dataBalance.Refresh();
dataBalance.Parent.Refresh();
和
d
浏览 1提问于2013-01-25得票数 0
回答已采纳
我们正在将驱动程序从3.2升级到4.x，以支持DSE 6.8。我们的应用程序目前支持的负载平衡策略是RoundRobinPolicy和DCAwareRoundRobinPolicy。这些策略在java驱动程序核心4.12中是不可用的。我们如何支持上面的policies.Please帮助。我们应用程序中的当前代码使用3.1.0.jar：
public static LoadBalancingPolicy getLoadBalancingPolicy(String loadBalanceStr, boolean isTokenAware) {
LoadBalancingPolicy
浏览 7提问于2022-06-17得票数 1
回答已采纳
我有两个端点。我希望它们能够负载均衡流量，并充当故障转移机制。所谓故障转移，我的意思是，当一个端点没有响应时(由于任何原因，目标服务关闭)，第二个端点接收所有流量。我使用以下配置：
<send>
<endpoint>
<loadbalance algorithm="org.apache.synapse.endpoints.algorithms.RoundRobin">
<endpoint name="bsz2_mock_ep1">
&l
浏览 2提问于2014-07-02得票数 0
我使用的是负载均衡模块。它适用于randomEngine，但不适用于RoundRobinEngine。有没有人能告诉我问题出在哪里：
const loadbalance = require('loadbalance');
const engine = loadbalance.roundRobin([
{ object: 'a', weight: 2 },
{ object: 'b', weight: 1 }
]);
const pick = engine.pick();
console.log(pick);
在上面的例子中，我每次都会得到
浏览 4提问于2020-01-30得票数 0
我们在JBoss 7.1.1应用服务器中为后端集群MySQL服务器(主主配置)配置XA数据源。以下是数据源配置：
<xa-datasource jndi-name="java:/datasoucrenew" pool-name="datasoucrenew" enabled="true" use-ccm="false">
<xa-datasource-property name="URL">
jdbc:m
浏览 0提问于2013-12-17得票数 0
回答已采纳
我已经编写了一个负载平衡器，它每10秒生成一个报告，并将其发送到localhost上的MINA服务器:9991或localhost上的MINA服务器:9992(如果第一个失败)。一旦MINA服务器接收到报告，他们就会更改它并将其发送回负载均衡器，后者将打印报告的正文。
public class MyApp_A {
public static void main(String... args) throws Exception {
// create CamelContext
CamelContext context = new DefaultCamel
浏览 1提问于2013-11-05得票数 0
回答已采纳
我在一个apache pulsar集群上工作，它工作得很好，但由于某种原因，当我尝试发送消息时，我开始收到以下消息：
ERROR [id: 0xc5de4911, L:/127.0.0.1:55672 - R:localhost/127.0.0.1:6650] Close connection becaues received internal-server error java.lang.IllegalArgumentException: bound must be positive
另外，我还收到以下错误：
persistent://global/mycluster-cluster1/ns
浏览 19提问于2019-07-22得票数 0
回答已采纳
有没有人有一个简单的例子思科ACE (6500刀片或4710)配置单臂负载平衡与SNAT？我有一个负载均衡器在一个数据中心，我想为服务器/服务在另一个LB。
我找到了以下文章：思科的NAT源，但这比我的情况要复杂一些。
类似于：
ACE: 10.1.1.1和ACE VIP: 10.1.1.2
Server1: 10.2.1.1和Server2: 10.2.1.2
客户: 10.3.1.1
例如：
客户机转到10.1.1.2，将SNAT作为10.1.1.1，然后将请求负载平衡到服务器1和2，然后服务器回复将返回到ACE，然后转发给客户端。
我意识到这有时会导致路由效率低下，所以如果有更好的方法
浏览 0提问于2009-05-18得票数 0
回答已采纳
我们的应用程序目前使用cassandra-driver-core-3.1.0，它实现了令牌感知的负载平衡策略。我们正在将驱动程序升级到java-driver-core-4.13.0，驱动程序中没有令牌感知策略。在Datastax文档中，提到了令牌感知是默认策略。我们应该为它编写一些代码吗?或者如果我们使用默认的负载平衡策略，DefaultLoadBalancingPolicy令牌感知将被处理？我是卡桑德拉的新手。有人能帮忙吗..。
import com.datastax.driver.core.policies.RoundRobinPolicy;
import com.datastax.dri
浏览 15提问于2022-06-19得票数 0
回答已采纳
使用Apache，我希望将文件发送到ftp服务器，如果无法访问此服务器，则希望将文件发送到备份ftp服务器。我用负载平衡器做的
<route id="ftp.failover">
<from uri="file:/path/to/files"/>
<loadBalance inheritErrorHandler="false">
<failover roundRobin="false" sticky="false"/>
<to uri=&
浏览 4提问于2016-09-27得票数 1
回答已采纳
这是路由：
<route>
<from uri="direct:xyz"/>
<loadBalance>
<failover maximumFailoverAttempts="2" roundRobin="false">
<exception>java.net.NoRouteToHostException</exception> </failover>
<to uri="http://URi1"/>
浏览 0提问于2015-10-07得票数 0
1回答
WSO2开发自定义端点
、、、
我需要扩展LoadBalance端点来开发我的自定义端点。我试过了：
1)
public class CustomLoadBalanceEndpoint extends LoadbalanceEndpoint
2)我使用/ wso2 /components/dropins文件夹中的dropins studio将其导出
3)我找不到在ESB中使用它的方法...我试着用下面的代码
<endpoint class="it.innovapuglia.sistemapuglia.wso2.enpoint.CustomLoadBalanceEndpoint"
浏览 0提问于2013-12-05得票数 0
1回答
NAT负载平衡
、、、
嗨，我有问题，通过NAT负载平衡的telnet。
当我尝试做telnet 192.168.192.100时总是返回:无法到达的目的地；网关或主机关闭
📷
路由器NAT配置：
Current configuration : 1366 bytes
!
version 12.4
service timestamps debug datetime msec
service timestamps log datetime msec
no service password-encryption
!
hostname NAT
!
boot-start-marker
boot-end-marker
!
!
n
浏览 0提问于2016-12-30得票数 1
回答已采纳
我在tomcat上部署了camel示例-servlet-tomcat-无弹簧示例。效果很好。我更改了camel-config.xml，但是我的错误很严重。
java.lang.IllegalArgumentException: Invalid uri: /camel-example/camel/hello. If you are forwarding/bridging http endpoints, then enable the bridgeEndpoint option on the endpoint: Endpoint[https://www.google.com]
at org
浏览 12提问于2013-12-02得票数 0
回答已采纳
如何公开StatefulSet服务(cassandra、mysql等)与ClusterIP=None在谷歌云平台上的库伯内特斯？
我需要更改ClusterIP配置吗？还是我需要配置Google？还是我需要改变其他东西？
谢谢
编辑:我想通过外部IP连接卡桑德拉，从互联网上的任何地方连接。
EDIT2:我猜解决方案是使用LoadBalance而不是ClusterIP，但是当我使用LoadBalance时，Cassandra节点找不到种子节点。然后，我使用ClusterIP=None连接Cassandra集群，并创建了另一个带有type=LoadBalance的POD，以连接到Cassandra并
浏览 0提问于2019-03-31得票数 1
回答已采纳
我通过骆驼制作http平衡器(安装JBoss熔断器在之前)
%fuse_dir%=c:\temp\jboss-fuse-6.2.1.redhat-084
%path%=%path%;%fuse_dir%\bin;
)
git clone https://github.com/mishin/http-balancer-camel.git
cd http-balancer-camel/smx-ws-examples-jboss-fuse-6.2.1
mvn clean install
fuse console
在fuse控制台中我们编写
JBossFuse:karaf@root> featu
浏览 1提问于2016-07-01得票数 3
回答已采纳
我正在尝试让我的Filebeat将日志传递到Logstash的多个实例。Filebeat可以有多个输出，但是它们是负载均衡的。 我尝试使用以下命令设置filebeat： output.logstash.hosts: ["IP1:5044", "IP2:5044"]
output.logstash.loadbalance: false 这会给我提供负载均衡IP1，直到该节点出现故障，然后切换到IP2。Loadbalance = false，当有多个主机时定义为默认值 另外，我也尝试过： output.logstash.hosts: ["IP1:5044&
浏览 70提问于2019-07-04得票数 0
1回答
我有一条骆驼路线，在收到大量信息时会被勒死。假设我定义的最大交换为每2秒3次，并且路由接收的次数超过了我希望将这些消息重定向到其他负载均衡器路由的限制。有人能帮我实现这个目标吗？
浏览 2提问于2015-05-25得票数 1
回答已采纳
2回答
我有一个多线程应用程序，我想在String上使用可重入锁。例如，如果我使用普通同步，我的代码将如下所示。
我不想让两个相同IPaddress的线程进入我的loadBalance()，所以我锁定了IP地址，它工作得很好。
class A {
String ipAddress;
...
void loadBalance() {
synchronized (ipAddress) {
// Business logic goes here
}
}
}
现在，如果我在这里使用required API，那么代码将看起来
浏览 18提问于2017-08-27得票数 1
我想把表达式写到文件中
- '{ "FRONTEND_URL":"http://$(pulumi stack output frontendUrl)" } >> cypress.env.json'
现在我得到了错误消息
Outputs:
backendUrl : "backend-loadbalance-6ac6577-668084404.eu-north-1.elb.amazonaws.com"
frontendUrl: "frontend-loadbalance-58e3866-175380
浏览 3提问于2021-12-22得票数 0
我读过wso2 api管理器active-active setup，但是我希望通过两个以上的节点来设置api管理器，例如三个节点。因此，我有些困惑，例如，我应该如何为3节点配置3节点在deployment.toml中的节流部分？
[apim.throttling]
event_duplicate_url = ["tcp://<node2-hostname>:<node2-port>"]
[[apim.throttling.url_group]]
traffic_manager_urls = ["tcp://<node1-hostname&
浏览 4提问于2021-08-09得票数 0
回答已采纳
我有一个简单的骆驼路线，一个Netty 4部分作为客户端到一个套接字。如果无法访问套接字，则将正确抛出java.net.ConnectException，但不会捕获onException配置部分，而是将其作为Exchange传递。有机会抓住这个吗？
骆驼2.16.1
Netty 4.0.3最后
Routebuilder
public void configure() throws Exception {
if (faultProcessor != null) {
onException(Exception.class).handled(true).pro
浏览 2提问于2016-01-26得票数 2
回答已采纳
2回答
我一直在做一个项目，该项目将建立一组高度可用的负载均衡器。负载平衡和高可用性软件似乎工作得很好(我使用Crossroads进行负载平衡，Keepalived使负载平衡服务器高度可用，Conntrackd用于负载均衡器的健康检查)，但我在设置Keepalived的配置文件以在发生状态转换时发送电子邮件时遇到问题(master->backup/backup->master)。我遵循手册页(man keepalived.conf)上的说明，告诉我如何设置电子邮件通知，但我无法在预期时间收到电子邮件。我倾向于拼写检查和简单的错误，但在检查这个问题近10个小时后，我似乎什么也找不到，并且没有
浏览 0提问于2011-06-25得票数 3
我在3个实例中运行了一个小型WebJob，WebJob由ServiceBusTrigger触发，每个作业大约需要20秒(我为测试添加了一个睡眠)。
现在，我将3个项添加到ServiceBus队列中，但只有2个WebJob实例工作。
第三个实例在做什么，如何让实例也在队列上工作？
我的代码非常基本：
public class Functions
{
// This function will get triggered/executed when a new message is written
// on an Azure Queue called q
浏览 1提问于2017-07-14得票数 0
回答已采纳
1回答
我正在学习monix 3。
下一个代码：
object Main extends TaskApp {
override def runc = {
Observable.fromIterable(1 to 10)
.map{i =>
val delay = Random.nextInt(1000) + 1000
println(s"Starting $i, delay = $delay")
Thread.sleep(delay) // Imitation of hard execution
浏览 0提问于2018-08-17得票数 0
回答已采纳
我试图在MySQL集群上测试负载平衡，并使用JMeter发送一些请求。JDBC数据库URL设置如下:jdbc:mysql:loadbalance://ip2 1，ip2/ndbinfo?loadBalanceBlacklistTimeout=5000
我的目的是打印发送给DB的每个请求，以包含ip1或ip2，以检查负载平衡功能。
我尝试过包括JSR223示例程序和java代码
import java.sql.Connection;
import org.apache.jmeter.protocol.jdbc.config.DataSourceElement;
Connection conn =
浏览 3提问于2014-06-05得票数 0
回答已采纳
我们的用户目前通过输入“我们的网站”访问我们的interal网站。有一个DNS条目，它将我们的网站映射到Cisco ACE 4700的ip地址。DNS名称ourwebsite.ourcompany.org还映射到Cisco 4700的ip地址。
我们希望让我们的用户开始使用ourwebsite.ourcompany.org，并取消他们使用“我们的网站”的能力。在一段时间内，我们希望“我们的网站”仍然带他们到我们的网站。
我们想知道是否可以配置Cisco 4700，这样如果用户在http://ourwebsite中键入，它就会立即重定向到http://ourwebsite.ourcompany.
浏览 0提问于2011-01-26得票数 0
我们正在尝试在我们的产品中实现断路器模式。我尝试实现它，并观察到，如果我给阈值为'0‘，它是工作的fine.but任何值>0，它只是等待2秒，并允许请求与外部rest服务通信。
我尝试了下面的简单例子，其中计时器组件每1秒触发一次消息，在我的处理器中，我编写了逻辑，它将抛出MyCustomException 3次，然后断路器将进入打开状态，它应该等待10秒，因为我在camel document.but中读取它只是简单地阻塞请求2秒，然后允许请求处理。
import org.apache.camel.CamelContext;
import org.apache.camel.bui
浏览 0提问于2015-11-25得票数 0
2回答
我有两个程序，由三个路由组成。
[
one is a route, from JPA database to bean.
one is a copier, from file system endpoint to file system endpoint
]
[
one is a uploader, from file system endpoint to bean.
]
我想运行一个基于属性文件输入的程序
<context:property-placeholder location="./run.properties"
ignore-re
浏览 1提问于2014-11-10得票数 2
5回答
防止多异步操作
、、、
我正在编写一些代码，在这些代码中，计时器每秒钟勾选一次，并从Webservice获取数据并显示在WInform上，
实现而不是的最佳方法是同时运行多个操作？
如果上一次操作完成而未运行，则应运行操作。
代码是
public void loadbalance()
{
try { //Get Data from Internet }
catch { }
}
delegate void loadbalancedelegate();
public void loadBalanceAsync()
{
loadba
浏览 4提问于2011-09-10得票数 1
回答已采纳
1回答
您好，我想在apache camel中基于SOAP会话执行粘性负载平衡，该会话嵌入在第一个响应的ServiceGroupID节点中。
我写了一条如下的小路线：
from(uri)
.loadBalance().sticky(xpath(query).namespaces(env).namespaces(wsa).namespaces(ax))
.to(BE1,BE2);
其中URI是请求被传递到的字符串，BE1和BE2是两个后端服务器。
我的问题是
String query = "/soapenv:Envelope/soapenv:Header/wsa:ReplyTo/wsa:Refe
浏览 1提问于2012-09-12得票数 0
我使用springcloud来构建系统，包括许多微服务。对于一些接口调用，我使用由@LoadBalance注释的resttemplate来实现负载均衡，并使用eureka作为注册中心。然而，当我调用不同微服务之间的接口时，resttemplate有时会连接到错误的服务。例如，我有服务A，B，C，当服务A调用服务B的接口时，由@LoadBalance注解的resttemplate会首先根据服务名称从eureka中找到实际的ip和端口，然后构建实际的url并将请求发送到目标服务器，但有时当我调用服务B的接口时，它会找到服务C的ip和端口，导致调用失败。这种情况很少发生，但从来没有消失过，我已经困
浏览 74提问于2019-12-13得票数 0
1回答
我正在研究一个建立在Camel和ActiveMQ上的数据管道。一种路由从队列中获取消息，并通过套接字上的Netty将其公开，以便C++组件获取它们：
<from uri="activemq:queue:inqueue?concurrentConsumers=1"/
<camel:loadBalance inheritErrorHandler="false">
<camel:roundRobin/>
<camel:to uri="netty:tcp://0.0.0.0:0?logicalName=comp#1
浏览 0提问于2015-05-29得票数 0
1回答
我正在尝试通过jdbc mysql驱动程序连接到mysql集群，该驱动程序包装在dbcp的basicDatasource中。
下面是我的bean配置：
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url
浏览 1提问于2012-12-06得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
