通過(guò)Docker啟動(dòng)Solace并在Spring?Boot通過(guò)JMS整合Solace的操作方法

更新時(shí)間：2023年01月18日 09:32:18 作者：南瓜慢說(shuō)

本文將介紹如何在Spring中使用，雖然代碼使用的是Spring Boot，但并沒(méi)有使用相關(guān)starter，跟Spring的整合一樣，可通用，JMS是通過(guò)的消息處理框架，可以深入學(xué)習(xí)一下，不同的MQ在JMS的整合上都是類(lèi)似的，感興趣的朋友跟隨小編一起看看吧

1 簡(jiǎn)介

Solace是一個(gè)強(qiáng)大的實(shí)時(shí)性的事件驅(qū)動(dòng)消息隊(duì)列。本文將介紹如何在Spring中使用，雖然代碼使用的是Spring Boot，但并沒(méi)有使用相關(guān)starter，跟Spring的整合一樣，可通用。JMS是通過(guò)的消息處理框架，可以深入學(xué)習(xí)一下，不同的MQ在JMS的整合上都是類(lèi)似的。

2 通過(guò)Docker啟動(dòng)Solace

有兩種方式試用Solace，一種是通過(guò)Docker來(lái)啟動(dòng)，另一種是使用Cloud版本，但Cloud版本有試用期限，我們使用Docker來(lái)啟動(dòng)吧。

先下載鏡像：

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

然后通過(guò)以下命令啟動(dòng)：

$ 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，是因?yàn)镸ac的原因。

然后便可以訪問(wèn)來(lái)登陸管理界面：http://localhost:8080/

用戶(hù)名密碼為：admin/admin

登陸后可以看到如下界面，Solace按VPN來(lái)管理隊(duì)列，VPN有點(diǎn)像分組，比如某個(gè)業(yè)務(wù)線使用某個(gè)VPN。

我們?cè)?code>default的VPN上創(chuàng)建一個(gè)Queue，名為pkslow-queue：

其它設(shè)置如下：

接著在該Queue上創(chuàng)建Topic：

創(chuàng)建完成后，我們可以直接測(cè)試一下：

可以Publish到Topic或Queue，也可以從其中一個(gè)Subscribe。

完成以上設(shè)置后，我們就可以在Spring Boot中整合了。

3 Spring Boot JMS整合Solace

3.1 發(fā)送消息

我們是通過(guò)JmsTemplate來(lái)發(fā)送消息的，而JmsTemplate需要連接到MQ，就需要一個(gè)ConnectionFactory，這個(gè)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后，就可以引用并發(fā)送消息了：

@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 接收消息

我們通過(guò)MessageListenerContainer來(lái)接收消息，MessageListenerContainer也需要一個(gè)ConnectionFactory，也有MQ的連接信息。還需要一個(gè)MessageListener，用來(lái)定義如何處理消息。我們的配置如下：

@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復(fù)用了在SolacePubConfig創(chuàng)建的對(duì)象。

3.3 測(cè)試

發(fā)送GET請(qǐng)求就可以觸發(fā)發(fā)送了：

GET http://localhost:8083/solace

我發(fā)了三次，結(jié)果日志如下：

4 代碼

代碼請(qǐng)看GitHub: https://github.com/LarryDpk/pkslow-samples

References:

Docker available image tags

Docker Solace Guide

Spring Solace

到此這篇關(guān)于通過(guò)Docker啟動(dòng)Solace，并在Spring Boot通過(guò)JMS整合Solace的文章就介紹到這了,更多相關(guān)Spring Boot通過(guò)JMS整合Solace內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: