动态创建的资源适配器
Dynamically creatable Resource Adapter
我们目前实施的 JCA TCP/IP 适配器需要重新评估，项目负责人向我传递了一个新的但重要的要求。
需要添加新的 TCP 连接并启动它们而不重新启动服务器。 （另外修改现有的）
目前只有向 standalone.xml 添加新的 属性 才有可能，这需要服务器的 restart/reload。
我查看了很多博客文章和 "tutorials" 关于使用 MDB 实现 JCA 的文章，我想我掌握了它的窍门，但我没有找到动态的方法，最好是通过代码, 创建新连接。
我想了想我可以将 ActivationSpec 与 ResourceAdapter 结合使用 class 但我不知道如何实现。
编辑：
我们的资源适配器无论如何都实现得很不正确，但我仍然会声明它是双向的。它可以侦听连接或打开连接并接收和发送消息。
资源适配器作为解压缩的 .rar 添加到 wildfly 模块系统，在
中包含 module.xml
C:\wildfly-10.0.0.Final\modules\com\company\server\TcpConnectorServerModule.1.0.0
module.xml的内容：
<?xml version="1.0" encoding="UTF-8"?>
<module xmlns="urn:jboss:module:1.1" name="com.company.server.TcpConnectorServerModule"
slot="5.1.0.0">
<resources>
<resource-root path="." />
</resources>
<dependencies>
<module name="javax.api"/>
<module name="javax.resource.api"/>
</dependencies>
</module>
standalone.xml中的内容：
<subsystem xmlns="urn:jboss:domain:ee:4.0">
<global-modules>
<module name="org.infinispan.cdi.embedded" slot="ispn-8.2"/>
<module name="org.jgroups" slot="ispn-8.2"/>
<module name="com.company.server.TcpConnectorServerModule" slot="5.1.0.0" meta-inf="true"/>
</global-modules>
TL;DR:
是否可以设计一个 JCA 资源适配器以动态（并希望通过代码）创建和修改连接而无需重新启动服务器？
如果不在 JCA 中重新启动是不可能的，我将不胜感激在 Wildfly 中启用 TCP/IP 连接到外部设备（打印机、扫描仪、秤等）的替代方法。我们需要能够在我们的业务逻辑中与这些设备进行交互。
有一个名为 auto-deploy-exploded and a second scenario is described here. I would first gather in a test environment experience with this feature, before you test it in production. I wrote a year ago a resource adapter test project and describe it on github 的热部署功能以及一些关于创建和使用的额外资源。希望对您有所帮助。
我发现虽然无法使用 CLI 添加新连接，因为我只能重新启动整个服务器而不是子系统，但使用 JMX 是可能的。
我可以通过操作 "activate" 添加与 JMX 和 "restart" 子系统的新连接。如果子系统已经处于活动状态，则该操作就像重新启动一样。
之后我可以像以前一样在我的应用程序中使用 InitialConext.listBindings() 函数获得新连接。
这是一个 JMX 脚本示例 Groovy:
import java.lang.management.ManagementFactory;
import javax.management.ObjectName;
import java.lang.String;
import java.lang.Integer;
import java.lang.Boolean;
import java.lang.Long;
import javax.management.openmbean.TabularData;
import javax.management.MBeanInfo;
def mBeanServer = ManagementFactory.getPlatformMBeanServer()
def tcpConnectorMBean = new ObjectName("jboss.as:subsystem=resource-adapters,resource-adapter=TCPConnector")
def definitionMBean = new ObjectName( "jboss.as:subsystem=resource-adapters,resource-adapter=TCPConnector,connection-definitions=*" )
println 'before test creation:'
printAvailableBeans(mBeanServer,definitionMBean, 'jndiName')
//createTcpConnection(mBeanServer,tcpConnectorMBean)
//println 'After test creation:'
//printAvailableBeans(mBeanServer,definitionMBean, 'jndiName')
/*
* After adding a new Connection and configuring the needed properties, the Resource Adapter needs to be (re)activated in order to register
* the newly added connection and make it available with the JNDI
*/
//activateBean(mBeanServer,tcpConnectorMBean)
/**
* This function retrieves the Object for the given name and tries to retrieve all MBeans for it and extracts some information of it.
*/
void printAvailableBeans(def mBeanServer, ObjectName objectName, String attribute){
mBeanServer.queryMBeans( objectName, null ).each {
print 'Class name: ' + it.className
print 'Object name : ' + it.name
print ' -> '
def handler = mBeanServer.getAttribute( it.name,attribute )
println handler
}
println ''
}
void createTcpConnection(def mBeanServer,ObjectName objectName){
final String name = 'TestJMX'
final Integer allocationRetry = null
final Long allocationRertyWaitMills = null
final Boolean backgroundValidation = null
final Long backgroundValidationMills = null
final Long blockingTimeoutWaitMills = null
final String capacityDecrementerClass = null
final TabularData capacityDecrementerProperties = null
final String capacityIncrementerClass = null
final TabularData capacityIncrementerProperties = null
final String className = 'TCPManagedConnectionFactory'
final Boolean connectable = false
final Boolean enabled = true
final Boolean enlistment = true
final Boolean enlistmentTrace = null
final String flushStrategy = 'FailingConnectionOnly'
final Long idleTimeoutMinutes = null
final Integer initialPoolSize = null
final Boolean interleaving = false
final String jndiName = 'java:/tcp/TestJMX'
final Integer maxPoolSize = 20
final String mcp = null
final Integer minPoolSize = 0
final Boolean noRecovery = false
final Boolean noTxSeparatePool = false
final Boolean padXid = false
final Boolean poolFair = true
final Boolean poolPrefill = false
final Boolean poolUseStrictMin = false
final String recoveryPassword = null
final String recoveryPluginClassName = null
final TabularData recoveryPluginProperties = null
final String recoverySecurityDomain = null
final String recoveryUsername = null
final Boolean sameRmOverride = null
final Boolean securityApplication = false
final String securityDomain = null
final String securityDomainAndApplication = null
final Boolean sharable = true
final Boolean tracking = null
final Boolean useCcm = true
final Boolean useFastFail = false
final Boolean useJavaContext = true
final Boolean validateOnMatch = null
final Boolean wrapXaResource = true
final Integer xaResourceTimeout = null
Object[] opParam =[name,allocationRetry,allocationRertyWaitMills,backgroundValidation,backgroundValidationMills,blockingTimeoutWaitMills,capacityDecrementerClass,capacityDecrementerProperties,capacityIncrementerClass,capacityIncrementerProperties,className,connectable,enabled,enlistment,enlistmentTrace,flushStrategy,idleTimeoutMinutes,initialPoolSize,interleaving,jndiName,maxPoolSize,mcp,minPoolSize,noRecovery,noTxSeparatePool,padXid,poolFair,poolPrefill,poolUseStrictMin,recoveryPassword,recoveryPluginClassName,recoveryPluginProperties,recoverySecurityDomain,recoveryUsername,sameRmOverride,securityApplication,securityDomain,securityDomainAndApplication,sharable,tracking,useCcm,useFastFail,useJavaContext,validateOnMatch,wrapXaResource,xaResourceTimeout]
String[] opSig = [name.getClass().getName(),allocationRetry.getClass().getName(),allocationRertyWaitMills.getClass().getName(),backgroundValidation.getClass().getName(),backgroundValidationMills.getClass().getName(),blockingTimeoutWaitMills.getClass().getName(),capacityDecrementerClass.getClass().getName(),capacityDecrementerProperties.getClass().getName(),capacityIncrementerClass.getClass().getName(),capacityIncrementerProperties.getClass().getName(),className.getClass().getName(),connectable.getClass().getName(),enabled.getClass().getName(),enlistment.getClass().getName(),enlistmentTrace.getClass().getName(),flushStrategy.getClass().getName(),idleTimeoutMinutes.getClass().getName(),initialPoolSize.getClass().getName(),interleaving.getClass().getName(),jndiName.getClass().getName(),maxPoolSize.getClass().getName(),mcp.getClass().getName(),minPoolSize.getClass().getName(),noRecovery.getClass().getName(),noTxSeparatePool.getClass().getName(),padXid.getClass().getName(),poolFair.getClass().getName(),poolPrefill.getClass().getName(),poolUseStrictMin.getClass().getName(),recoveryPassword.getClass().getName(),recoveryPluginClassName.getClass().getName(),recoveryPluginProperties.getClass().getName(),recoverySecurityDomain.getClass().getName(),recoveryUsername.getClass().getName(),sameRmOverride.getClass().getName(),securityApplication.getClass().getName(),securityDomain.getClass().getName(),securityDomainAndApplication.getClass().getName(),sharable.getClass().getName(),tracking.getClass().getName(),useCcm.getClass().getName(),useFastFail.getClass().getName(),useJavaContext.getClass().getName(),validateOnMatch.getClass().getName(),wrapXaResource.getClass().getName(),xaResourceTimeout.getClass().getName()]
mBeanServer.invoke(objectName,'addConnectionDefinitions',opParam,opSig)
}
void activateBean(def mBeanServer, ObjectName mBean){
Object[] opParam = []
String[] opSig = []
mBeanServer.invoke(mBean, 'activate', opParam, opSig)
}
return
我们目前实施的 JCA TCP/IP 适配器需要重新评估，项目负责人向我传递了一个新的但重要的要求。
需要添加新的 TCP 连接并启动它们而不重新启动服务器。 （另外修改现有的） 目前只有向 standalone.xml 添加新的 属性 才有可能，这需要服务器的 restart/reload。
我查看了很多博客文章和 "tutorials" 关于使用 MDB 实现 JCA 的文章，我想我掌握了它的窍门，但我没有找到动态的方法，最好是通过代码, 创建新连接。
我想了想我可以将 ActivationSpec 与 ResourceAdapter 结合使用 class 但我不知道如何实现。
编辑： 我们的资源适配器无论如何都实现得很不正确，但我仍然会声明它是双向的。它可以侦听连接或打开连接并接收和发送消息。
资源适配器作为解压缩的 .rar 添加到 wildfly 模块系统，在
中包含 module.xmlC:\wildfly-10.0.0.Final\modules\com\company\server\TcpConnectorServerModule.1.0.0
module.xml的内容：
<?xml version="1.0" encoding="UTF-8"?>
<module xmlns="urn:jboss:module:1.1" name="com.company.server.TcpConnectorServerModule"
slot="5.1.0.0">
<resources>
<resource-root path="." />
</resources>
<dependencies>
<module name="javax.api"/>
<module name="javax.resource.api"/>
</dependencies>
</module>
standalone.xml中的内容：
<subsystem xmlns="urn:jboss:domain:ee:4.0">
<global-modules>
<module name="org.infinispan.cdi.embedded" slot="ispn-8.2"/>
<module name="org.jgroups" slot="ispn-8.2"/>
<module name="com.company.server.TcpConnectorServerModule" slot="5.1.0.0" meta-inf="true"/>
</global-modules>
TL;DR:
是否可以设计一个 JCA 资源适配器以动态（并希望通过代码）创建和修改连接而无需重新启动服务器？
如果不在 JCA 中重新启动是不可能的，我将不胜感激在 Wildfly 中启用 TCP/IP 连接到外部设备（打印机、扫描仪、秤等）的替代方法。我们需要能够在我们的业务逻辑中与这些设备进行交互。
有一个名为 auto-deploy-exploded and a second scenario is described here. I would first gather in a test environment experience with this feature, before you test it in production. I wrote a year ago a resource adapter test project and describe it on github 的热部署功能以及一些关于创建和使用的额外资源。希望对您有所帮助。
我发现虽然无法使用 CLI 添加新连接，因为我只能重新启动整个服务器而不是子系统，但使用 JMX 是可能的。
我可以通过操作 "activate" 添加与 JMX 和 "restart" 子系统的新连接。如果子系统已经处于活动状态，则该操作就像重新启动一样。
之后我可以像以前一样在我的应用程序中使用 InitialConext.listBindings() 函数获得新连接。
这是一个 JMX 脚本示例 Groovy:
import java.lang.management.ManagementFactory;
import javax.management.ObjectName;
import java.lang.String;
import java.lang.Integer;
import java.lang.Boolean;
import java.lang.Long;
import javax.management.openmbean.TabularData;
import javax.management.MBeanInfo;
def mBeanServer = ManagementFactory.getPlatformMBeanServer()
def tcpConnectorMBean = new ObjectName("jboss.as:subsystem=resource-adapters,resource-adapter=TCPConnector")
def definitionMBean = new ObjectName( "jboss.as:subsystem=resource-adapters,resource-adapter=TCPConnector,connection-definitions=*" )
println 'before test creation:'
printAvailableBeans(mBeanServer,definitionMBean, 'jndiName')
//createTcpConnection(mBeanServer,tcpConnectorMBean)
//println 'After test creation:'
//printAvailableBeans(mBeanServer,definitionMBean, 'jndiName')
/*
* After adding a new Connection and configuring the needed properties, the Resource Adapter needs to be (re)activated in order to register
* the newly added connection and make it available with the JNDI
*/
//activateBean(mBeanServer,tcpConnectorMBean)
/**
* This function retrieves the Object for the given name and tries to retrieve all MBeans for it and extracts some information of it.
*/
void printAvailableBeans(def mBeanServer, ObjectName objectName, String attribute){
mBeanServer.queryMBeans( objectName, null ).each {
print 'Class name: ' + it.className
print 'Object name : ' + it.name
print ' -> '
def handler = mBeanServer.getAttribute( it.name,attribute )
println handler
}
println ''
}
void createTcpConnection(def mBeanServer,ObjectName objectName){
final String name = 'TestJMX'
final Integer allocationRetry = null
final Long allocationRertyWaitMills = null
final Boolean backgroundValidation = null
final Long backgroundValidationMills = null
final Long blockingTimeoutWaitMills = null
final String capacityDecrementerClass = null
final TabularData capacityDecrementerProperties = null
final String capacityIncrementerClass = null
final TabularData capacityIncrementerProperties = null
final String className = 'TCPManagedConnectionFactory'
final Boolean connectable = false
final Boolean enabled = true
final Boolean enlistment = true
final Boolean enlistmentTrace = null
final String flushStrategy = 'FailingConnectionOnly'
final Long idleTimeoutMinutes = null
final Integer initialPoolSize = null
final Boolean interleaving = false
final String jndiName = 'java:/tcp/TestJMX'
final Integer maxPoolSize = 20
final String mcp = null
final Integer minPoolSize = 0
final Boolean noRecovery = false
final Boolean noTxSeparatePool = false
final Boolean padXid = false
final Boolean poolFair = true
final Boolean poolPrefill = false
final Boolean poolUseStrictMin = false
final String recoveryPassword = null
final String recoveryPluginClassName = null
final TabularData recoveryPluginProperties = null
final String recoverySecurityDomain = null
final String recoveryUsername = null
final Boolean sameRmOverride = null
final Boolean securityApplication = false
final String securityDomain = null
final String securityDomainAndApplication = null
final Boolean sharable = true
final Boolean tracking = null
final Boolean useCcm = true
final Boolean useFastFail = false
final Boolean useJavaContext = true
final Boolean validateOnMatch = null
final Boolean wrapXaResource = true
final Integer xaResourceTimeout = null
Object[] opParam =[name,allocationRetry,allocationRertyWaitMills,backgroundValidation,backgroundValidationMills,blockingTimeoutWaitMills,capacityDecrementerClass,capacityDecrementerProperties,capacityIncrementerClass,capacityIncrementerProperties,className,connectable,enabled,enlistment,enlistmentTrace,flushStrategy,idleTimeoutMinutes,initialPoolSize,interleaving,jndiName,maxPoolSize,mcp,minPoolSize,noRecovery,noTxSeparatePool,padXid,poolFair,poolPrefill,poolUseStrictMin,recoveryPassword,recoveryPluginClassName,recoveryPluginProperties,recoverySecurityDomain,recoveryUsername,sameRmOverride,securityApplication,securityDomain,securityDomainAndApplication,sharable,tracking,useCcm,useFastFail,useJavaContext,validateOnMatch,wrapXaResource,xaResourceTimeout]
String[] opSig = [name.getClass().getName(),allocationRetry.getClass().getName(),allocationRertyWaitMills.getClass().getName(),backgroundValidation.getClass().getName(),backgroundValidationMills.getClass().getName(),blockingTimeoutWaitMills.getClass().getName(),capacityDecrementerClass.getClass().getName(),capacityDecrementerProperties.getClass().getName(),capacityIncrementerClass.getClass().getName(),capacityIncrementerProperties.getClass().getName(),className.getClass().getName(),connectable.getClass().getName(),enabled.getClass().getName(),enlistment.getClass().getName(),enlistmentTrace.getClass().getName(),flushStrategy.getClass().getName(),idleTimeoutMinutes.getClass().getName(),initialPoolSize.getClass().getName(),interleaving.getClass().getName(),jndiName.getClass().getName(),maxPoolSize.getClass().getName(),mcp.getClass().getName(),minPoolSize.getClass().getName(),noRecovery.getClass().getName(),noTxSeparatePool.getClass().getName(),padXid.getClass().getName(),poolFair.getClass().getName(),poolPrefill.getClass().getName(),poolUseStrictMin.getClass().getName(),recoveryPassword.getClass().getName(),recoveryPluginClassName.getClass().getName(),recoveryPluginProperties.getClass().getName(),recoverySecurityDomain.getClass().getName(),recoveryUsername.getClass().getName(),sameRmOverride.getClass().getName(),securityApplication.getClass().getName(),securityDomain.getClass().getName(),securityDomainAndApplication.getClass().getName(),sharable.getClass().getName(),tracking.getClass().getName(),useCcm.getClass().getName(),useFastFail.getClass().getName(),useJavaContext.getClass().getName(),validateOnMatch.getClass().getName(),wrapXaResource.getClass().getName(),xaResourceTimeout.getClass().getName()]
mBeanServer.invoke(objectName,'addConnectionDefinitions',opParam,opSig)
}
void activateBean(def mBeanServer, ObjectName mBean){
Object[] opParam = []
String[] opSig = []
mBeanServer.invoke(mBean, 'activate', opParam, opSig)
}
return