Sam's Notes | Sam Blog

梦想还是要有的，万一实现了呢

0%

activemq （二） 集成Spring-远程调用

发表于 更新于 分类于

上篇介绍了 activemq 的安装和使用，这篇介绍下集成 spring 最简单的运用，远程调用。注意，这种方式是没有事务控制的。

加入activemq 的 jar

maven 方式

1
2
3
4
5
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-all</artifactId>
    <version>5.12.0</version>
</dependency>

辅助类

  • 接口（服务端和客户端都要有）

    1
    2
    3
    4
    5
    6
    7
    8
    9
    public interface IGmGameAchvService
    {
    	/**
    	 * 根据ID获取对象
    	 * @param companyId
    	 * @return
    	 */
    	GmGameAchvEntity findById(Long id);
    }

  • 实现（服务端）

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    @Service("GmGameAchvServiceImpl")
    public class GmGameAchvServiceImpl implements IGmGameAchvService
    {

        @Override
        public GmGameAchvEntity findById(Long id)
        {
    	GmGameAchvEntity achv = new GmGameAchvEntity();
    	achv.setId(1L);
            return achv;
        }
    }

配置

概要

如下内容服务端和客户端都需要配置
1 jmsConnectionFactory
2 jmsQueue

服务端另需配置
3 MessageListenerContainer
4 ServiceExporter

客户端另需配置
5 ProxyFactoryBean

具体内容

以下都是java based的配置，xml的配置可以参考 Spring doc

  • jmsConnectionFactory jmsQueue
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@Configuration
public class JmsConfiguration
{

    @Bean
    public ActiveMQConnectionFactory jmsConnectionFactory(){
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL("tcp://localhost:61616");
        return connectionFactory;
    }


    @Bean
    public ActiveMQQueue jmsQueue(){
        ActiveMQQueue queue = new ActiveMQQueue("spring-activemq");
        return queue;
    }
}

  • 服务端

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    @Configuration
    public class JmsServerConfiguration
    {

        @Autowired
        private IGmGameAchvService gameAchvService;

        @Autowired
        private ActiveMQConnectionFactory jmsConnectionFactory;

        @Autowired
        private ActiveMQQueue jmsQueue;

        @Bean
        public JmsInvokerServiceExporter service()
        {
            JmsInvokerServiceExporter service = new JmsInvokerServiceExporter();
            service.setServiceInterface(IGmGameAchvService.class);
            service.setService(gameAchvService);

            return service;
        }

        @Bean
        public SimpleMessageListenerContainer msgListenerContainer()
        {
            SimpleMessageListenerContainer msgListenerContainer = new SimpleMessageListenerContainer();
            msgListenerContainer.setConnectionFactory(jmsConnectionFactory);
            msgListenerContainer.setDestination(jmsQueue);
            msgListenerContainer.setConcurrentConsumers(3);
            msgListenerContainer.setMessageListener(service());
            return msgListenerContainer;
        }
    }

  • 客户端
    配置

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    @Configuration
    public class JmsClientConfiguration
    {
        @Autowired
        private ActiveMQConnectionFactory jmsConnectionFactory;

        @Autowired
        private ActiveMQQueue jmsQueue;

        @Bean
        public JmsInvokerProxyFactoryBean achvService()
        {
            JmsInvokerProxyFactoryBean service = new JmsInvokerProxyFactoryBean();
            service.setServiceInterface(IGmGameAchvService.class);
            service.setConnectionFactory(jmsConnectionFactory);
            service.setQueue(jmsQueue);
            return service;
        }

    }

调用

1
2
3
4
5
6
7
8
9
10
11
IGmGameAchvService gmservice = (IGmGameAchvService) service;
GmGameAchvEntity achv = gmservice.findById(1L);
if (achv == null)
{
    System.out.println("achv is null");
}
else
{
    System.out.println("achv id=" + achv.getId());
}

监控

正常启动后， 在 activemq 的监控中可以看到相应内容。
如
Queues
connections

activemq集合贴