金融投资管理公司网站源码,wordpress批量tag,博客网站开发框架,上海百度推广官方电话下一篇文章将演示如何将Spring JMS模板和DLMC与AmazonSQS API一起使用#xff0c;以放置消息队列。 我为什么要使用Amazon SQS#xff1f; 易于配置 跨平台支持 从您的自我冗余#xff0c;连带和扩展方面的烦恼中赚钱。 为什么我不使用Amazon SQS#xff1f; 如果延迟… 下一篇文章将演示如何将Spring JMS模板和DLMC与AmazonSQS API一起使用以放置消息队列。 我为什么要使用Amazon SQS 易于配置 跨平台支持 从您的自我冗余连带和扩展方面的烦恼中赚钱。 为什么我不使用Amazon SQS 如果延迟要求少于〜20 MS 每封邮件的费用约为0.00005 $ 我遇到了一个很好的开源项目Nevado它以非常简洁的方式包装了Amazon SQS API。 将此添加到您的Maven依赖项 dependencygroupIdorg.skyscreamer/groupIdartifactIdnevado-jms/artifactIdversion1.2.4/version/dependency 现在让我们配置Spring bean使其与AmazonSQS很好地集成 1.连接工厂 bean idsqsConnectorFactory classorg.skyscreamer.nevado.jms.connector.amazonaws.AmazonAwsSQSConnectorFactory/ 请注意在此包装器中我们需要设置aws.accessKey和aws.secretKey。 我们从AmazonSQS帐户门户获取这些密钥 bean idconnectionFactory classorg.skyscreamer.nevado.jms.NevadoConnectionFactoryproperty namesqsConnectorFactory refsqsConnectorFactory/property nameawsAccessKey value${aws.accessKey}/property nameawsSecretKey value${aws.secretKey}//bean2.创建队列 bean idmyQueue classorg.skyscreamer.nevado.jms.destination.NevadoQueueconstructor-arg value${aws.sqs.queue.name}//bean3.创建Jms模板稍后将在代码中注入它以发送消息 bean idjmsTemplate classorg.springframework.jms.core.JmsTemplateproperty namedefaultDestinationName value${aws.sqs.queue.name}/property nameconnectionFactory refcachedConnectionFactory//bean4.添加监听器 4.a我正在使用SimpleMessageListenerContainer它具有缓存连接运行并发使用者设置错误侦听器等功能。 bean idsimpleMessageListenerContainer classorg.springframework.jms.listener.SimpleMessageListenerContainerproperty nameconnectionFactory refconnectionFactory/property namemessageListener reflistener/property namedestination refmyQueue/property nameerrorHandler refamazonMessageListener/property nameconcurrency value20/property nametaskExecutor reflistenerThreadPoolTaskExecutor//bean 4.b让我们为侦听器的执行者添加线程池 bean idlistenerThreadPoolTaskExecutor classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutorproperty namecorePoolSize value70/property namemaxPoolSize value70/property namedaemon valuetrue/property namekeepAliveSeconds value60//bean 4.c添加缓存连接支持 bean idcachedConnectionFactory classorg.springframework.jms.connection.CachingConnectionFactoryproperty nametargetConnectionFactory refconnectionFactory/property namesessionCacheSize value10//bean 4.d创建MessageAdapter来挂接所有内容并将pojo设置为我们的消息监听器amazonMessageListener bean idlistener classorg.springframework.jms.listener.adapter.MessageListenerAdapterproperty namedelegate refamazonMessageListener/property namedefaultListenerMethod valueonMessage/property namedefaultResponseDestination refmyQueue//bean 参考 AmazonSQS和Spring在IdanFridman.com博客上提供了来自JCG合作伙伴 Idan Fridman的消息队列 。 翻译自: https://www.javacodegeeks.com/2014/01/amazonsqs-and-spring-for-messaging-queue.html
