脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Spring Boot通过JMS整合Solace

通过Docker启动Solace并在Spring Boot通过JMS整合Solace的操作方法

 更新时间：2023年01月18日 09:32:18   作者：南瓜慢说  
本文将介绍如何在Spring中使用，虽然代码使用的是Spring Boot，但并没有使用相关starter，跟Spring的整合一样，可通用，JMS是通过的消息处理框架，可以深入学习一下，不同的MQ在JMS的整合上都是类似的，感兴趣的朋友跟随小编一起看看吧

1 简介

Solace是一个强大的实时性的事件驱动消息队列。本文将介绍如何在Spring中使用，虽然代码使用的是Spring Boot，但并没有使用相关starter，跟Spring的整合一样，可通用。JMS是通过的消息处理框架，可以深入学习一下，不同的MQ在JMS的整合上都是类似的。

2 通过Docker启动Solace

有两种方式试用Solace，一种是通过Docker来启动，另一种是使用Cloud版本，但Cloud版本有试用期限，我们使用Docker来启动吧。

先下载镜像：

$ docker pull solace/solace-pubsub-standard:9.13.0.16

然后通过以下命令启动：

$ docker run -d -p 8080:8080 -p 55554:55555 -p 8008:8008 -p 1883:1883 -p 8000:8000 -p 5672:5672 -p 9000:9000 -p 2222:2222 --shm-size=2g --env username_admin_globalaccesslevel=admin --env username_admin_password=admin --name=solace solace/solace-pubsub-standard:9.13.0.16

这里端口改为55554，是因为Mac的原因。

然后便可以访问来登陆管理界面：http://localhost:8080/

用户名密码为：admin/admin

登陆后可以看到如下界面，Solace按VPN来管理队列，VPN有点像分组，比如某个业务线使用某个VPN。

我们在default的VPN上创建一个Queue，名为pkslow-queue：

其它设置如下：

接着在该Queue上创建Topic：

创建完成后，我们可以直接测试一下：

可以Publish到Topic或Queue，也可以从其中一个Subscribe。

完成以上设置后，我们就可以在Spring Boot中整合了。

3 Spring Boot JMS整合Solace

3.1 发送消息

我们是通过JmsTemplate来发送消息的，而JmsTemplate需要连接到MQ，就需要一个ConnectionFactory，这个Factory是带着MQ的一些连接信息。配置代码如下：

@Configuration
public class SolacePubConfig {

    private final SolaceProperties solaceProperties;

    public SolacePubConfig(SolaceProperties solaceProperties) {
        this.solaceProperties = solaceProperties;
    }

    @Bean("connectionFactory")
    public ConnectionFactory connectionFactory() throws Exception {
        Properties env = new Properties();
        env.put(InitialContext.INITIAL_CONTEXT_FACTORY, "com.solacesystems.jndi.SolJNDIInitialContextFactory");
        env.put(InitialContext.PROVIDER_URL, solaceProperties.getBrokerUrl());
        env.put(SupportedProperty.SOLACE_JMS_VPN, solaceProperties.getVpn());
        env.put(InitialContext.SECURITY_PRINCIPAL, solaceProperties.getUsername());
        env.put(InitialContext.SECURITY_CREDENTIALS, solaceProperties.getPassword());
        return SolJmsUtility.createConnectionFactory(env);
    }

    @Bean
    public CachingConnectionFactory cachingConnectionFactory(ConnectionFactory connectionFactory) {
        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(connectionFactory);
        cachingConnectionFactory.setSessionCacheSize(10);
        return cachingConnectionFactory;
    }

    @Bean
    public JmsTemplate pubJmsTemplate(CachingConnectionFactory cachingConnectionFactory) {
        JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory);
        jmsTemplate.setPubSubDomain(true);
        jmsTemplate.setExplicitQosEnabled(true);
        jmsTemplate.setDeliveryPersistent(true);
        jmsTemplate.setDefaultDestinationName(solaceProperties.getDefaultPubDestinationName());
        return jmsTemplate;
    }
}

生成JmsTemplate后，就可以引用并发送消息了：

@RestController
@RequestMapping("/solace")
public class SolaceTestController {
    private final JmsTemplate pubJmsTemplate;
    private final SolaceProperties solaceProperties;

    public SolaceTestController(JmsTemplate pubJmsTemplate, SolaceProperties solaceProperties) {
        this.pubJmsTemplate = pubJmsTemplate;
        this.solaceProperties = solaceProperties;
    }

    @GetMapping
    public String send() {
        pubJmsTemplate.send(solaceProperties.getDefaultPubDestinationName(), session -> session.createTextMessage("www.pkslow.com"));
        pubJmsTemplate.send(session -> session.createTextMessage("Larry Deng"));
        return "OK";
    }
}

用到的属性配置如下：

server.port=8083

pkslow.solace.brokerUrl=smf://127.0.0.1:55554
pkslow.solace.vpn=default
pkslow.solace.username=default
pkslow.solace.password=default
pkslow.solace.defaultPubDestinationName=pkslow-topic
pkslow.solace.defaultSubDestinationName=pkslow-queue
@Configuration
@ConfigurationProperties(prefix = "pkslow.solace")
@Setter
@Getter
public class SolaceProperties {
    private String brokerUrl;
    private String vpn;
    private String username;
    private String password;
    private String defaultPubDestinationName;
    private String defaultSubDestinationName;
}

3.2 接收消息

我们通过MessageListenerContainer来接收消息，MessageListenerContainer也需要一个ConnectionFactory，也有MQ的连接信息。还需要一个MessageListener，用来定义如何处理消息。我们的配置如下：

@Configuration
@Slf4j
public class SolaceSubConfig {
    private final SolaceProperties solaceProperties;

    public SolaceSubConfig(SolaceProperties solaceProperties) {
        this.solaceProperties = solaceProperties;
    }

    @Bean
    public SingleConnectionFactory singleConnectionFactory(@Qualifier("connectionFactory") ConnectionFactory targetConnectionFactory) {
        return new SingleConnectionFactory(targetConnectionFactory);
    }

    @Bean
    public MessageListener messageListener() {
        return message -> {
            try {
                log.info("Received message " + ((TextMessage) message).getText() + " on destination: " +
                        message.getJMSDestination().toString());
            } catch (JMSException ex) {
                throw new RuntimeException(ex);
            }
        };
    }
    @Bean
    public MessageListenerContainer messageListenerContainer(SingleConnectionFactory singleConnectionFactory, MessageListener messageListener) {
        DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
        container.setConnectionFactory(singleConnectionFactory);
        container.setDestinationName(solaceProperties.getDefaultSubDestinationName());
        container.setMessageListener(messageListener);

        return container;
    }
}

这里@Qualifier("connectionFactory") ConnectionFactory targetConnectionFactory复用了在SolacePubConfig创建的对象。

3.3 测试

发送GET请求就可以触发发送了：

GET http://localhost:8083/solace

我发了三次，结果日志如下：

4 代码

代码请看GitHub: https://github.com/LarryDpk/pkslow-samples

References:

Docker available image tags

Docker Solace Guide

Spring Solace

到此这篇关于通过Docker启动Solace，并在Spring Boot通过JMS整合Solace的文章就介绍到这了,更多相关Spring Boot通过JMS整合Solace内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

相关文章

  • 一文详细解析Java 8 Stream API中的flatMap方法

    一文详细解析Java 8 Stream API中的flatMap方法

    这篇文章主要介绍了Java 8 Stream API中的flatMap方法的相关资料,flatMap方法是Java StreamAPI中的重要中间操作,用于将流中的每个元素转换为一个新的流,并将多个流合并为一个单一的流,常用于处理嵌套集合和一对多映射,需要的朋友可以参考下
    2024-12-12
  • Java中ArrayList的使用详细介绍

    Java中ArrayList的使用详细介绍

    这篇文章主要介绍了Java中ArrayList的使用，本文给大家详细讲述该相关的知识点，并且会通过大量的案例加以说明,需要的朋友可以参考一下
    2022-04-04
  • 彻底搞懂Java多线程(二)

    彻底搞懂Java多线程(二)

    这篇文章主要给大家介绍了关于Java面试题之多线程和高并发的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用java具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2021-07-07
  • Java继承方法重写实现原理及解析

    Java继承方法重写实现原理及解析

    这篇文章主要介绍了Java继承方法重写实现原理及解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • 分享Java开发必须掌握的日志分析命令

    分享Java开发必须掌握的日志分析命令

    这篇文章主要介绍了分享Java开发必须掌握的日志分析命令，在日常工作中，如果我们遇到线上问题，一般的处理步骤应该是先保留现场，然后再考虑回滚，之后再是解决问题
    2019-07-07
  • Java分布式锁理论(redis、zookeeper))案例详解

    Java分布式锁理论(redis、zookeeper))案例详解

    zookeeper有个节点路径的概念,节点路径不能重复,保证了唯一性,这篇文章给大家介绍Java分布式锁理论(redis、zookeeper) 案例详解,感兴趣的朋友跟随小编一起看看吧
    2024-01-01
  • springboot如何去除debug日志

    springboot如何去除debug日志

    这篇文章主要介绍了springboot如何去除debug日志的方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-06-06
  • 关于Java语法糖以及语法糖的原理和用法

    关于Java语法糖以及语法糖的原理和用法

    这篇文章主要介绍了关于Java什么是语法糖以及语法糖的种类,也称糖衣语法，是由英国计算机学家 Peter.J.Landin 发明的一个术语，指在计算机语言中添加的某种语法，这种语法对语言的功能并没有影响，但是更方便程序员使用,需要的朋友可以参考下
    2023-05-05
  • Spring无法接收List<event>的解决方案

    Spring无法接收List<event>的解决方案

    在日常开发中,我们常使用 Spring 的 @EventListener 注解来监听事件,但在处理 批量事件 时,却可能遇到一些“看似合理但无法生效”的监听方式,本文以实际具体案例为出发点,结合源码分析事件派发逻辑,并给出两种可行解决方案,需要的朋友可以参考下
    2025-04-04
  • java ThreadPoolExecutor线程池拒绝策略避坑

    java ThreadPoolExecutor线程池拒绝策略避坑

    这篇文章主要为大家介绍了java ThreadPoolExecutor拒绝策略避坑踩坑示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-07-07

最新评论