在Spring集成中动态创建服务激活器

Question

我有一个Web服务，每个版本将有多个版本和多个类。我想在启动时动态创建服务激活器，这样我就可以减少配置量，从而更容易维护。开发人员可以放入一个新类，SI会自动拾取它。

我编码了一个Application Listener：

public class SpringContextListener implements ApplicationListener<ContextRefreshedEvent> {
    public void onApplicationEvent(ContextRefreshedEvent event) {
        System.out.println("ApplicationListener Invoked At Spring Container Startup");

                String s = "com.ps.snt.MyClass";
                Class c = Class.forName(s);

                ServiceActivatingHandler serviceActivator;
                serviceActivator = new ServiceActivatingHandler(c.newInstance());
                serviceActivator.setComponentName("MyClassBean");
                // also tried setBeanName
        }
}

稍后在路由器中，我有以下代码：

protected Collection<MessageChannel> determineTargetChannels(Message<?> message) {

        List<MessageChannel> channels = new ArrayList<MessageChannel>();

        MessageChannel channel = (MessageChannel)this.getBeanFactory().getBean("MyClassBean", ServiceActivatingHandler.class);
        channels.add(channel);
        return channels;
    }

但当路由器尝试路由时，我会出现以下错误：

 org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'MyClassBean' is defined

我该怎么做？我需要动态创建服务激活器，并在以后将消息路由到这些激活器。

<int:service-activator input-channel="MyClassBean">
        <bean class="com.ps.snt.ws.MyClassBean" />
    </int:service-activator>

没有办法在ServiceActivatingHandler上设置输入通道，所以我需要创建一个同名通道并订阅激活器吗？这是代码，仍然收到相同的错误：

String s = "com.ps.snt.MyClass";
Class c = Class.forName(s);

DirectChannel channel = new DirectChannel();
channel.setBeanName("MyClassBean");

ServiceActivatingHandler serviceActivator;
serviceActivator = new ServiceActivatingHandler(c.newInstance());

channel.subscribe(serviceActivator);

更新：我必须在创建通道后注册bean。这段代码成功了：

DirectChannel channel = new DirectChannel();
channel.setBeanName("MyClassBean");

ServiceActivatingHandler serviceActivator;
serviceActivator = new ServiceActivatingHandler(c.newInstance());

channel.subscribe(serviceActivator);

ConfigurableListableBeanFactory beanFactory = ((ConfigurableApplicationContext) context).getBeanFactory();
beanFactory.registerSingleton("MyClassBean", channel);

我的新问题是：这是一种可行的方法，还是会导致后续问题？

Answer 1

如果它应该是动态/运行时的，那么您就不会硬编码SA bean类名。

如果您可以对您的部署和运行时环境提出一些见解，也许我可以提出更好的方法。您的目标不明确（开发人员可以放弃SA类，SI会自动获取它）。