问题标签 [wso2mb]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
40 浏览

java - 如何查询 JMS 队列的元素而不删除它们

早上好,我在 wso2 消息代理中有一个队列。我想知道在java中是否有一种方法可以在不删除队列的元素的情况下查询它们。我尝试使用 QueueBrowser 但应用程序出错了(我的问题 --> JMS: Server closed connection and reconnection not allowed)。连接是正确的,因为如果我创建一个消费者,它对我有用,我想知道你是否知道另一种方式。

谢谢你。

0 投票
1 回答
493 浏览

oauth-2.0 - 针对 WSO2 消息代理的 MQTT Oauth2 身份验证

我想让 MQTT 代理向 OAUTH2 服务器进行身份验证。

我正在使用 Paho 在 Python 3 中编写 MQTT 客户端。

我已成功连接到 IS 以获取访问令牌。

我已通过 MQTT 消息代理成功发送 json 消息。

我已按照官方说明配置 WSO2 Message Broker 和 Identity Server 一起工作。

当我尝试连接身份验证信息时,我无法正确发送要处理的访问令牌。

在日志中我看到了这个:

如何将访问令牌发送到要访问的服务器?Message Broker 在哪里搜索访问令牌?

0 投票
1 回答
184 浏览

wso2 - 如何使用 AdminServices 在 WSO2 MB 中获取主题中的消息计数

为了从主题中获取消息计数,我调用了 WSO2 MB 3.1.0 AdminService api 调用。它适用于队列,但不适用于主题。使用主题调用时,它没有给出正确的计数(它总是给出 0)
(为了在 WSO2 MB 管理控制台中显示主题中的消息计数,我在 WSO2 ESB 中创建了一个具有挂起状态的入站端点并创建了一个持久订阅到主题)

  1. 从队列中获取消息计数。
    网址:https://localhost:9447/services/AndesAdminService.AndesAdminServiceHttpsSoap12Endpoint

请求正文:

  1. 从主题获取消息计数。

网址:https://localhost:9447/services/AndesAdminService.AndesAdminServiceHttpsSoap12Endpoint

请求正文:

我将 messagePattern 设置为“主题”以获取主题中的消息计数。这不正确吗?如果是这样,那么使用管理服务获取主题中的消息计数的正确方法是什么。

参考: https ://docs.wso2.com/display/MB310/Calling+Admin+Services+from+Apps

0 投票
0 回答
60 浏览

wso2 - WSO2 ESB 5.0.0 - 它可以容纳的最大流量

我正在尝试分析 wso2 ESB 5.0.0 在生产环境中可以占用或保持的最大流量。

  1. 就像我们可以在具有 2 WSO2 MB 的集群中的两台服务器中部署多少 API?
  2. 每个 API 或整个 API 每分钟可以进行的最大调用次数是多少?

我们有 2 个 ESB 和 2 MB 服务器在一个集群中运行。ESB:16 GB RAM 100GB HD MB:4 GB RAM 100GB HD

任何信息都会有所帮助。

0 投票
1 回答
681 浏览

wso2 - WSO2 ESB (4.9.0) / MB (3.1.0) - 无法连接到代理(连接被拒绝)

我在运行 Ubuntu 16.04.5 LTS 的服务器上安装的驱动器上安装了 WSO2 ESB (4.9.0) 和 WS02 MB (3.1.0)。

ESB 配置了 API 端点,这些端点在发布请求时将接收到的数据推送到消息代理。这个过程完美无缺,直到我通过典型的更新命令更新服务器,即,, sudo apt-get update然后 重新启动系统。sudo apt-get upgradesudo apt-get dist-upgrade

重新启动并启动 MB,然后启动 ESB(均通过 手动sh wso2server.sh)后,我从 ESB 收到以下错误:

错误 - 通过工厂“QueueConnectionFactory”创建连接时出现 JMSConnectionFactory JMS 异常无法连接到代理 URL:tcp://localhost:61616。原因:java.net.ConnectException:连接被拒绝(连接被拒绝)

WARN - JMSPollingConsumer 入站 JMS 端点无法获得连接。

这显然会阻止 ESB 向 MB 发送消息。这可能是什么原因造成的?

附带说明一下,通过非 root 帐户尝试相同的过程会导致以下错误:

错误:未正确定义 JAVA_HOME。CARBON 无法执行 java

Message Broker 以 root 身份登录(省略部分):

root@[REDACTED]:/mnt/wso2mb-3.1.0/wso2mb-3.1.0/bin# sh wso2server.sh JAVA_HOME 环境变量设置为 /usr/lib/jvm/java-8-oracle CARBON_HOME 环境变量设置到 /mnt/wso2mb-3.1.0/wso2mb-3.1.0 Java HotSpot(TM) 64 位服务器 VM 警告:忽略选项 MaxPermSize=256m;8.0 中删除了支持 [2019-02-06 14:01:34,947] WARN {org.apache.axiom.util.stax.dialect.StAXDialectDetector} - 无法在 bundleresource://13.fwk1845904670 确定 StAX 实现的方言/ [2019-02-06 14:01:34,947] WARN {org.apache.axiom.util.stax.dialect.StAXDialectDetector} - 无法在 bundleresource://13.fwk1845904670/ INFO {org 确定 StAX 实现的方言.wso2.andes.wso2.internal.QpidBundleActivator} - 在 PluginManager [2019-02-06 14:01:35,921] 信息 {org.wso2.carbon.core. CarbonCoreActivator} - Java 临时目录:/mnt/wso2mb-3.1.0/wso2mb-3.1.0/tmp [2019-02-06 14:01:35,924] 信息 {org.wso2.carbon.core.internal.CarbonCoreActivator} -用户:root,en-GB,Etc/GMT [2019-02-06 14:01:36,067] WARN {org.wso2.carbon.core.bootup.validator.util.ValidationResultPrinter} - Carbon 配置为使用默认密钥库(wso2carbon.jks)。为了在部署到生产环境时最大限度地提高安全性,请在生产服务器配置文件中配置具有唯一密码的新密钥库。[2019-02-06 14:01:36,073] 信息 {org.wso2.carbon.databridge.agent.thrift.AgentHolder} - 代理创建![2019-02-06 14:01:36,093] INFO {org.wso2.carbon.databridge.agent.thrift.internal.AgentDS} - 成功部署代理客户端 [2019-02-06 14:01:37,935] INFO {org .wso2.carbon.registry.core.jdbc。AbstractReporter} - 为 Metrics [2019-02-06 14:01:38,327] 启动 JMX 报告器] INFO {org.wso2.carbon.user.core.internal.UserStoreMgtDSComponent} - Carbon UserStoreMgtDSComponent 成功激活。[2019-02-06 14:01:45,805] INFO {org.apache.axis2.deployment.ClusterBuilder} - 集群已禁用 [2019-02-06 14:01:45,966] INFO {org.wso2.carbon.identity .user.store.configuration.deployer.UserStoreConfigurationDeployer} - 用户存储配置部署器已启动。[2019-02-06 14:01:45,966] INFO {org.wso2.carbon.identity.user.store.configuration.deployer.UserStoreConfigurationDeployer} - 用户存储配置部署程序已启动。[2019-02-06 14:01:46,056] INFO {org.apache.axis2.deployment.ModuleDeployer} - 部署模块:addressing-1.6.1-wso2v16 - file:/mnt/wso2mb-3.1.0/wso2mb-3.1 . 0/repository/deployment/client/modules/addressing-1.6.1-wso2v16.mar [2019-02-06 14:01:46,060] INFO {org.apache.axis2.deployment.ModuleDeployer} - 部署模块:rampart-1.6 .1-wso2v10 - 文件:/mnt/wso2mb-3.1.0/wso2mb-3.1.0/repository/deployment/client/modules/rampart-1.6.1-wso2v10.mar [2019-02-06 14:01:46,334 ] INFO {org.apache.axis2.deployment.DeploymentEngine} - 部署 Web 服务:org.wso2.carbon.andes.admin-3.1.1 - [2019-02-06 14:01:46,368] INFO {org.apache. axis2.deployment.DeploymentEngine} - 部署 Web 服务:org.wso2.carbon.andes.event.admin-3.1.1 - [2019-02-06 14:01:46,710] WARN {org.apache.axis2.description.java2wsdl .DefaultSchemaGenerator} - 我们不支持方法重载。忽略 [validateAudienceRestriction] [2019-02-06 14:01:47,285] 信息 {org.apache.axis2.deployment. 90849 [2019-02-06 14:01:47,891] INFO {org.wso2.andes.server.management.JMXManagedObjectRegistry} - 使用 jplatform MBean 服务器初始化托管对象注册表 [2019-02-06 14:01:47,896] INFO { org.wso2.andes.server.security.auth.manager.PrincipalDatabaseAuthenticationManager} - PrincipalDatabase 具体实现:org.wso2.carbon.andes.authentication.andes.CarbonBasedPrincipalDatabase [2019-02-06 14:01:47,900] INFO {org. wso2.andes.server.security.auth.manager.PrincipalDatabaseAuthenticationManager} - 已成功初始化 PLAIN SASL 提供程序 [2019-02-06 14:01:47,900] 信息 {org.wso2.andes.server.security.auth.manager.PrincipalDatabaseAuthenticationManager} - 其他 SASL 提供商已成功注册。[2019-02-06 14:01:47,900] 信息 {org.wso2.andes.server.security.auth.manager. RDBMSMessageStoreImpl} - 消息存储已初始化 [2019-02-06 14:01:48,067] INFO {org.wso2.andes.kernel.AndesKernelBoot} - 使用 org.wso2.andes.store.rdbms.RDBMSMessageStoreImpl 初始化的 Andes MessageStore [2019-02 -06 14:01:48,144] 信息 {org.wso2.andes.kernel.Andes} - Andes API 已初始化。信息 {org.wso2.carbon.core.init.JMXServerManager} - JMX 服务 URL:service:jmx:rmi://localhost:11112/jndi/rmi://localhost:10000/jmxrmi [2019-02-06 14: 01:49,974] 信息 {org.wso2.carbon.core.internal.StartupFinalizerServiceComponent} - 服务器:WSO2 Message Broker-3.1.0 [2019-02-06 14:01:49,975] 信息 {org.wso2.carbon.core. internal.StartupFinalizerServiceComponent} - WSO2 Carbon 在 16 秒内开始 [2019-02-06 14:01:50,176] 信息 {org.wso2.carbon.ui.internal.CarbonUIServiceComponent} - 管理控制台 URL:067] INFO {org.wso2.andes.kernel.AndesKernelBoot} - 使用 org.wso2.andes.store.rdbms.RDBMSMessageStoreImpl [2019-02-06 14:01:48,144] INFO {org.wso2.andes. kernel.Andes} - 初始化 Andes API。信息 {org.wso2.carbon.core.init.JMXServerManager} - JMX 服务 URL:service:jmx:rmi://localhost:11112/jndi/rmi://localhost:10000/jmxrmi [2019-02-06 14: 01:49,974] 信息 {org.wso2.carbon.core.internal.StartupFinalizerServiceComponent} - 服务器:WSO2 Message Broker-3.1.0 [2019-02-06 14:01:49,975] 信息 {org.wso2.carbon.core. internal.StartupFinalizerServiceComponent} - WSO2 Carbon 在 16 秒内开始 [2019-02-06 14:01:50,176] 信息 {org.wso2.carbon.ui.internal.CarbonUIServiceComponent} - 管理控制台 URL:067] INFO {org.wso2.andes.kernel.AndesKernelBoot} - 使用 org.wso2.andes.store.rdbms.RDBMSMessageStoreImpl [2019-02-06 14:01:48,144] INFO {org.wso2.andes. kernel.Andes} - 初始化 Andes API。信息 {org.wso2.carbon.core.init.JMXServerManager} - JMX 服务 URL:service:jmx:rmi://localhost:11112/jndi/rmi://localhost:10000/jmxrmi [2019-02-06 14: 01:49,974] 信息 {org.wso2.carbon.core.internal.StartupFinalizerServiceComponent} - 服务器:WSO2 Message Broker-3.1.0 [2019-02-06 14:01:49,975] 信息 {org.wso2.carbon.core. internal.StartupFinalizerServiceComponent} - WSO2 Carbon 在 16 秒内开始 [2019-02-06 14:01:50,176] 信息 {org.wso2.carbon.ui.internal.CarbonUIServiceComponent} - 管理控制台 URL:store.rdbms.RDBMSMessageStoreImpl [2019-02-06 14:01:48,144] INFO {org.wso2.andes.kernel.Andes} - Andes API 已初始化。信息 {org.wso2.carbon.core.init.JMXServerManager} - JMX 服务 URL:service:jmx:rmi://localhost:11112/jndi/rmi://localhost:10000/jmxrmi [2019-02-06 14: 01:49,974] 信息 {org.wso2.carbon.core.internal.StartupFinalizerServiceComponent} - 服务器:WSO2 Message Broker-3.1.0 [2019-02-06 14:01:49,975] 信息 {org.wso2.carbon.core. internal.StartupFinalizerServiceComponent} - WSO2 Carbon 在 16 秒内开始 [2019-02-06 14:01:50,176] 信息 {org.wso2.carbon.ui.internal.CarbonUIServiceComponent} - 管理控制台 URL:store.rdbms.RDBMSMessageStoreImpl [2019-02-06 14:01:48,144] INFO {org.wso2.andes.kernel.Andes} - Andes API 已初始化。信息 {org.wso2.carbon.core.init.JMXServerManager} - JMX 服务 URL:service:jmx:rmi://localhost:11112/jndi/rmi://localhost:10000/jmxrmi [2019-02-06 14: 01:49,974] 信息 {org.wso2.carbon.core.internal.StartupFinalizerServiceComponent} - 服务器:WSO2 Message Broker-3.1.0 [2019-02-06 14:01:49,975] 信息 {org.wso2.carbon.core. internal.StartupFinalizerServiceComponent} - WSO2 Carbon 在 16 秒内开始 [2019-02-06 14:01:50,176] 信息 {org.wso2.carbon.ui.internal.CarbonUIServiceComponent} - 管理控制台 URL:https://[已编辑]:9444/carbon/ [2019-02-06 14:06:45,627] INFO {org.wso2.andes.kernel.AndesChannel} - 频道已创建(ID:127.0.0.1:53018)[2019-02-06 14:06:45,743] INFO { org.wso2.andes.subscription.SubscriptionEngine} - 本地订阅添加 [[REDACTED]]ID=0@[REDACTED]/[REDACTED]/T=1549462005677/D=true/X=false/O=null/E=amq .direct/ET=org.wso2.andes.server.exchange.DirectExchange$1@61094da2/EUD=0/S=true [2019-02-06 14:06:46,630] 信息 {org.wso2.andes.kernel.AndesChannel } - 已创建频道(ID:127.0.0.1:53022)[2019-02-06 14:06:46,663] 信息 {org.wso2.andes.subscription.SubscriptionEngine} - 本地订阅已添加 [[已编辑]]ID=1@ [已编辑]/[已编辑]/T=1549462006662/D=true/X=false/O=null/E=amq.direct/ET=org.wso2.andes.server.exchange.DirectExchange$1@61094da2/EUD=0 /S=true [2019-02-06 14:06:47,636] 信息 {org.wso2.andes.kernel.AndesChannel} - 创建的频道(ID:127.0.0.1:53026)[2019-02-06 14:06:48,677] INFO {org.wso2.andes.kernel.AndesChannel} - 创建的频道(ID:127.0.0.1:53030) [2019-02-06 14:06:49,678] INFO {org.wso2.andes.kernel.AndesChannel} - 频道已创建(ID:127.0.0.1:53034)[2019-02-06 14:06:49,691] INFO { org.wso2.andes.subscription.SubscriptionEngine} - 本地订阅添加 [[REDACTED]]ID=4@[REDACTED]/[REDACTED]/T=1549462009690/D=true/X=false/O=null/E=amq .direct/ET=org.wso2.andes.server.exchange.DirectExchange$1@61094da2/EUD=0/S=true [2019-02-06 14:06:50,689] 信息 {org.wso2.andes.kernel.AndesChannel } - 频道已创建(ID:127.0.0.1:53040)[2019-02-06 14:06:50,762] INFO {org.wso2.andes.subscription.SubscriptionEngine} - 本地订阅添加 [[REDACTED]]ID=5@[REDACTED]/[REDACTED]/T=1549462010761/D=false/X=true/O=clientID/E=amq.topic/ET=org.wso2 .andes.server.exchange.TopicExchange$1@74034026/EUD=0/S=true [2019-02-06 14:06:51,719] INFO {org.wso2.andes.kernel.AndesChannel} - 频道已创建(ID:127.0 .0.1:53044)[2019-02-06 14:06:52,739] INFO {org.wso2.andes.kernel.AndesChannel} - 频道已创建(ID:127.0.0.1:53048)[2019-02-06 14:06 :53,784] INFO {org.wso2.andes.kernel.AndesChannel} - 频道创建(ID:127.0.0.1:53052)[2019-02-06 14:06:54,771] INFO {org.wso2.andes.kernel.AndesChannel } - 频道已创建(ID:127.0.0.1:53056)[2019-02-06 14:06:54,784] 信息 {org.wso2.andes.subscription.SubscriptionEngine} - 本地订阅已添加 [[已编辑]]ID=9@ [已编辑]/[已编辑]/T=1549462014782/D=true/X=false/O=null/E=amq。直接/ET=org.wso2.andes.server.exchange.DirectExchange$1@61094da2/EUD=0/S=true

ESB 日志作为根(省略部分):

root@[REDACTED]:/mnt/wso2esb-4.9.0/wso2esb-4.9.0/bin# sh wso2server.sh JAVA_HOME 环境变量设置为 /usr/lib/jvm/java-8-oracle CARBON_HOME 环境变量设置到 /mnt/wso2esb-4.9.0/wso2esb-4.9.0 Java HotSpot(TM) 64 位服务器 VM 警告:忽略选项 MaxPermSize=256m;8.0 中删除了支持 [2019-02-06 14:06:27,453] 信息 - CarbonCoreActivator 启动 WSO2 Carbon... [2019-02-06 14:06:27,458] 信息 - CarbonCoreActivator 操作系统:Linux 4.4.0-141 -通用,amd64 [2019-02-06 14:06:27,458] 信息 - CarbonCoreActivator Java 主页:/usr/lib/jvm/java-8-oracle/jre [2019-02-06 14:06:27,459] 信息 - CarbonCoreActivator Java 版本:1.8.0_201 [2019-02-06 14:06:27,459] 信息 - CarbonCoreActivator Java VM:Java HotSpot(TM) 64-Bit Server VM 25.201-b09,Oracle Corporation [2019-02-06 14:06:27,459] 信息 - CarbonCoreActivator Carbon 主页:/mnt/wso2esb-4.9.0/wso2esb-4.9.0 [2019-02-06 14:06:27,459] 信息 - CarbonCoreActivator Java 临时目录:/mnt/wso2esb-4.9。 0/wso2esb-4.9.0/tmp [2019-02-06 14:06:27,460] 信息 - CarbonCoreActivator 用户:root、en-GB、Etc/GMT [2019-02-06 14:06:27,629] 警告 - ValidationResultPrinter Carbon 配置为使用默认密钥库 (wso2carbon.jks)。为了在部署到生产环境时最大限度地提高安全性,请在生产服务器配置文件中配置具有唯一密码的新密钥库。[2019-02-06 14:06:27,639] 信息 - AgentHolder 代理已创建![2019-02-06 14:06:27,671] INFO - AgentDS 成功部署代理客户端 [2019-02-06 14:06:30,171] INFO - EmbeddedRegistryService 在 81 毫秒内配置注册表 [2019-02-06 14:06:30,221] 信息 - RegistryCoreServiceComponent 注册表模式:读写 [2019-02-06 14:06:32,887] 信息 - SolrClient 默认嵌入式 Solr 服务器已初始化 [2019-02-06 14:06:33,288] 信息 - UserStoreMgtDSComponent Carbon UserStoreMgtDSComponent 成功激活. [2019-02-06 14:06:40,096] 信息 - TaglibUriRule TLD 已跳过。网址:http://tiles.apache.org/tags-tiles已定义 [2019-02-06 14:06:40,764] 信息 - ClusterBuilder 集群已禁用 [2019-02-06 14:06:40,926] 信息 - UserStoreConfigurationDeployer 用户存储配置部署程序已启动。[2019-02-06 14:06:40,926] 信息 - UserStoreConfigurationDeployer 用户存储配置部署程序已启动。[2019-02-06 14:06:40,949] INFO - JMSSender JMS Sender 已启动 [2019-02-06 14:06:40,951] INFO - JMSSender JMS Transport Sender 已初始化... [2019-02-06 14:06: 40,951] 信息 - PassThroughHttpSender 正在初始化直通 HTTP/S 发送器... [2019-02-06 14:06:40,996] 信息 - PassThroughHttpSender 直通 HTTP 发送器已启动... [2019-02-06 14:06: 40,997] 信息 - PassThroughHttpSSLSender 正在初始化直通 HTTP/S 发送器... [2019-02-06 14:06:41,063] INFO - PassThroughHttpListener 正在初始化传递 HTTP/S 监听器... [2019-02-06 14:06:41,095] 信息 - PassThroughHttpSSLListener 正在初始化传递 HTTP/S 监听器... [2019-02-06 14: 06:41,175] INFO - ModuleDeployer 部署模块:addressing-1.6.1-wso2v14 - file:/mnt/wso2esb-4.9.0/wso2esb-4.9.0/repository/deployment/client/modules/addressing-1.6.1-wso2v14 .mar [2019-02-06 14:06:41,178] 信息 - ModuleDeployer 部署模块:rampart-1.6.1-wso2v12 - 文件:/mnt/wso2esb-4.9.0/wso2esb-4.9.0/repository/deployment/client /modules/rampart-1.6.1-wso2v12.mar [2019-02-06 14:06:42,074] 警告 - DefaultSchemaGenerator 我们不支持方法重载。忽略 [validateAudienceRestriction] [2019-02-06 14:06:42,356] INFO - DeploymentEngine 部署 Web 服务:org.wso2.carbon.message.processor-4.4.10 - [2019-02-06 14:511] INFO - RuleEngineConfigDS 成功注册了 Rule Config 服务 [2019-02-06 14:06:43,550] INFO - ServiceBusInitializer 正在启动 ESB... [2019-02-06 14:06:43,564] INFO - ServiceBusInitializer 正在初始化 Apache Synapse。 .. [2019-02-06 14:06:43,571] 信息 - SynapseControllerFactory 使用 Synapse 主页:/mnt/wso2esb-4.9.0/wso2esb-4.9.0/。[2019-02-06 14:06:43,573] 信息 - SynapseControllerFactory 使用 synapse.xml 位置:/mnt/wso2esb-4.9.0/wso2esb-4.9.0/././repository/deployment/server/synapse-configs/默认 [2019-02-06 14:06:43,573] INFO - SynapseControllerFactory 使用服务器名称:localhost [2019-02-06 14:06:43,580] INFO - SynapseControllerFactory 超时处理程序将每运行一次:15 秒 [2019-02-06 14:06:43,594] 信息 - Axis2SynapseController 初始化 Synapse 时间:2 月 6 日星期三 14:06:43 GMT 2019 [2019-02-06 14:06:43,605] INFO - CarbonSynapseController 从文件系统加载中介配置 [2019-02-06 14:06:43,608] INFO - MultiXMLConfigurationBuilder 从突触工件存储库构建突触配置: ././repository/deployment/server/synapse-configs/default [2019-02-06 14:06:43,613] INFO - XMLConfigurationBuilder 通过解析 XML 配置生成 Synapse 配置模型 [2019-02-06 14:06 :43,735] INFO - MessageStoreFactory 已成功添加消息存储配置:[JMSMS]。[2019-02-06 14:06:43,737] INFO - MessageStoreFactory 已成功添加消息存储配置:[WSO2MS]。[2019-02-06 14:06:43,752] 信息 - SynapseConfigurationBuilder 从位于 ./ 的工件存储库中加载了 Synapse 配置。https://[已编辑]:9443/carbon/ [2019-02-06 14:06:57,206] 错误 - 通过工厂“QueueConnectionFactory”创建连接时出现 JMSConnectionFactory JMS 异常无法连接到代理 URL:tcp://localhost: 61616。原因:java.net.ConnectException:连接被拒绝(连接被拒绝)[2019-02-06 14:06:57,207] 警告 - JMSPollingConsumer 入站 JMS 端点无法获得连接。

0 投票
1 回答
126 浏览

wso2 - WSO2 企业集成商 + WSO2 消息代理

我需要部署消息代理。但是不清楚我是否也必须运行 ESB 配置文件。我正在关注本指南https://dzone.com/articles/wso2-enterprise-integrator-with-a-message-broker-p,似乎需要 ESB 配置文件。这是对的吗?将 ESB 配置文件与 MB 配置文件一起运行有什么意义?谢谢

0 投票
1 回答
205 浏览

wso2 - 集群 WSO2 EI ESB 和 WSO2 EI MB 配置文件,WKA 与多播?我的假设正确吗?

我必须创建和配置一个两节点 WSO2 EI 集群。特别是我必须集群一个ESB配置文件和MB配置文件。

我对此有一些架构上的疑问:

集群 ESB 配置文件疑问:

我的假设基于此文档:https ://docs.wso2.com/display/EI640/Clustering+the+ESB+Profile

我找到了这个部分:

请注意,某些生产环境不支持多播。但是,如果您的环境支持多播,则将其用作您的会员计划没有问题

不支持多播的原因可能是什么?(所以我可以告知它可能存在的问题)。查看表格(在上一个链接中),在我看来,可能的问题可能与以下几点有关:

  • 所有节点都应该在同一个子网中
  • 所有节点都应该在同一个多播域中
  • 不应阻止多播

从系统\网络工程师那里获得这些信息是否足以决定是否继续使用多播选项?

使用多播而不是 WKA,我是否需要执行与“安装注册表”和“创建\连接到数据库”相关的第一个部署场景(基于 WKA)中列出的相同配置步骤(如第一个文档链接中所示)?

当我向集群添加新节点时,使用多播而不是WKA是否允许我不停止服务?

集群 MB 配置文件:

据我了解,MB个人资料集群只能使用WKA作为会员计划。使用WKA是否意味着当我向集群添加新节点时必须停止服务?

那么最后我们是否可以将 ESB 集群和 MB 集群视为两个不同的集群呢?ESB 集群(如果使用多播配置)是否需要在添加新节点时停止服务,而 MB 集群停止添加新节点?

0 投票
1 回答
81 浏览

wso2 - 我必须为这样的 WSO2 EI 两节点集群创建多少数据库和哪些数据库(每个节点包含 ESB 和 MB 配置文件)

我正在安装一个 WSO2 EI 两节点集群,我对必须创建的数据库数量有些怀疑。

我将尽我所能解释我的情况:我正在使用WSO2 EI 6.5.0

我有两个节点集群。每个节点都包含ESBMB配置文件。我将在Microsoft SQL Server集群数据库上创建所需的数据库。

所以我有这种情况:

节点 1:ESB 和 MB

节点 2:ESB 和 MB

阅读官方文档:

集群 WSO2 ESB 配置文件: https ://docs.wso2.com/display/EI650/Clustered+Deployment

集群 WSO2 MB 配置文件: https ://docs.wso2.com/display/EI650/Clustering+the+Message+Broker+Profile

我可以找到 ESB 和 MB 配置文件所需的数据库信息。特别是ESB配置文件需要创建这 4 个数据库:

  • WSO2_USER_DB: JDBC 用户存储和授权管理器。
  • REGISTRY_DB:用于配置和治理注册表安装在产品节点中的共享数据库。
  • REGISTRY_LOCAL1:节点 1 中的本地注册表空间。
  • REGISTRY_LOCAL2:节点 2 中的本地注册表空间。

MB配置文件需要以下 5 个数据库:

  • WSO2_USER_DB: JDBC 用户存储和授权管理器。
  • REGISTRY_DB:用于配置和治理注册表安装在产品节点中的共享数据库。
  • REGISTRY_LOCAL1:节点 1 中的本地注册表空间。
  • REGISTRY_LOCAL2:节点 2 中的本地注册表空间。
  • MB_DB:存储特定于消息代理配置文件的实例数据。

因此, ESBMB配置文件之间的前 4 个数据库似乎是相同的,并且MB配置文件使用了一个名为MB_DB的成瘾数据库。

我的疑问是:在像我这样的情况下(2 个节点集群,同时包含ESBMB配置文件)我必须创建多少个数据库?

我最初的想法是 5 个数据库,因为我认为前 4 个数据库在ESBMB配置文件之间共享,但现在我有以下疑问:理论上(如果我的断言错误,请纠正我)ESB 和 MB 都可以使用相同的用户数据库和注册表,但检查默认的H2设置,我们有:

  • ESB配置文件使用一个位于/usr/lib/wso2/wso2ei/6.5.0/repository/database/中的数据库
  • MB配置文件使用一个位于/usr/lib/wso2/wso2ei/6.5.0/wso2/broker/repository/database/中的数据库

所以理论上这应该意味着最好不要在配置文件/产品之间混合数据库。

那我到底应该怎么做?我必须创建多少和哪些数据库?

我现在在想,也许我必须使用前缀完全分离ESBMB配置文件数据库,如下所示:

ESB配置文件数据库:我必须创建这 4 个数据库:

  • ESB_WSO2_USER_DB
  • ESB_REGISTRY_DB
  • ESB_REGISTRY_LOCAL1
  • ESB_REGISTRY_LOCAL2

MB配置文件数据库:我必须创建这5个数据库;

  • MB_WSO2_USER_DB
  • MB_REGISTRY_DB
  • MB_REGISTRY_LOCAL1
  • MB_REGISTRY_LOCAL2
  • WSO2_MB(特定于MB配置文件,所以我没有使用冗余后缀)

这会是一个好的解决方案吗?但是通过这种方式,我将拥有完全独立的数据库,而不是为用户和注册表共享信息。

在像我这样的两个节点集群的情况下,最佳实践是什么?

谢谢

0 投票
1 回答
57 浏览

wso2 - 如何正确保证 WSO2 MB 配置文件集群的高可用性要求?

关于如何正确设置 WSO2 MB 集群以满足高可用性的要求,我有以下疑问。我正在关注这个官方指南:https ://docs.wso2.com/display/EI650/Clustering+the+Message+Broker+Profile#ClusteringtheMessageBrokerProfile-Testingthecluster

所以我将有一个两个节点的 WSO2 MB 配置文件集群。现在我的疑问与高可用性概念有关(基本上:如果单个节点不工作,集群应该仍然工作)。

我有两个节点集群,每个节点都在具有特定 IP 地址的特定服务器上运行,就像这样

节点 1 的 IP:XXX.XXX.XXX.1

NODE 2 的 IP:XXX.XXX.XXX.2

因此,假设我想将消息发布到此集群上定义的队列中。我想我可以将消息冷漠地发送到这两个节点之一(如果我做错了断言,请纠正我)。

如果是这种情况:如何保证高可用性要求?我可以简单地将我的两个节点都放在负载均衡器下吗?这样如果一个节点不工作,请求就会被定向到另一个节点

这是处理这种情况的正确方法吗?

0 投票
1 回答
299 浏览

wso2 - 完成 wso2 mb 教程后无法运行 wso2 esb

我正在努力赶上 wso2ei 7 的新版本并正在关注新教程,但是当我再次启动 esb 时出现以下错误,我一直收到错误消息

存储 [PaymentRequestMessageStore]。无法初始化 JMS 消息存储。错误:无法使用哈希表中指定的工厂创建 InitialContext。初始上下文工厂:[org.wso2.andes.jndi.PropertiesFileInitialContextFactory]; 提供者网址:[null]; 连接工厂:[null]。javax.naming.NoInitialContextException:无法使用哈希表中指定的工厂创建 InitialContext。[根异常是 java.lang.ClassNotFoundException:未找到类 org.wso2.andes.jndi.PropertiesFileInitialContextFactory] ​​在 org.wso2.micro.core.context.CarbonContextDataHolder$CarbonInitialJNDIContextFactoryBuilder.createInitialContextFactory(CarbonContextDataHolder.java:301) 在 javax.naming .spi.NamingManager.getInitialContext(NamingManager.java:681) 在 javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:

...

任何人都可以帮助我吗?

[编辑]

我从 cmd 启动了 esb,我得到了一个不同的错误,我不知道是否有帮助......

错误 {org.apache.axis2.transport.jms.JMSConnectionFactoryManager} - 设置连接工厂时出错:myQueueSender org.apache.axis2.transport.jms.AxisJMSException:无法获取 JNDI 上下文,JMS 连接工厂:QueueConnectionFactory 或默认目的地:null JMS CF:myQueueSender 使用:{transport.jms.CacheLevel=producer,broker_name=wso2mb,transport.jms.ConnectionFactoryType=queue,java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory,transport.jms.ConnectionFactoryJNDIName =QueueConnectionFactory, java.naming.provider.url=conf/jndi.properties} 在 org.apache.axis2.transport.jms.JMSConnectionFactory.initJMSConnectionFactory(JMSConnectionFactory.java:188) 在 org.apache.axis2.transport.jms.JMSConnectionFactory .(JMSConnectionFactory.java:152) 在 org.apache.axis2.transport.jms。JMSConnectionFactoryManager.loadConnectionFactoryDe​​finitions(JMSConnectionFactoryManager.java:89)
...