美文网首页
给aws sqs发队列消息

给aws sqs发队列消息

作者: 牧笛2017 | 来源:发表于2019-03-13 23:21 被阅读0次

1.引入包:

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-aws-messaging</artifactId>
        </dependency>

2.在配置文件yml中定义队列的名字,并且定义一个参数类,在这个类中定义priceChangedSqs为aws里的队列名字。

3.配置一个QueueMessagingTemplate类引用这个sqs队列

@Configuration
public class ApplicationConfiguration {

    private final PricingProperties pricingProperties;

    @Autowired
    public ApplicationConfiguration(
                    final PricingProperties pricingProperties ) {
        this.pricingProperties = pricingProperties;
    }

    @Bean
    public QueueMessagingTemplate queueMessagingTemplate( final AmazonSQSAsync amazonSQSAsync,
                                                          final ResourceIdResolver resourceIdResolver ) {
        final QueueMessagingTemplate queueMessagingTemplate = new QueueMessagingTemplate( amazonSQSAsync, resourceIdResolver );
        queueMessagingTemplate.setDefaultDestinationName( pricingProperties.getPriceChangedSqs() ); // 通过第二步,获取yml里的队列名

        return queueMessagingTemplate;
    }

}

4.使用 queueMessagingTemplate 发送消息

public class PriceSendToSqs {
    private final QueueMessagingTemplate queueMessagingTemplate;
    public void sendToSqs(  SupplierArticlePrice price ) {
      ExchangeableArticlePrice exchangeableArticlePrice = new ExchangeableArticlePrice( price );
            queueMessagingTemplate.convertAndSend( exchangeableArticlePrice );
        }
}

相关文章

  • 给aws sqs发队列消息

    1.引入包: 2.在配置文件yml中定义队列的名字,并且定义一个参数类,在这个类中定义priceChangedSq...

  • AWS SQS队列服务实例的创建和Spring Boot、JMS

    一、SQS是什么? SQS 是AWS提供的队列产品,可让您集成和分离分布式软件系统。 二、获取访问密钥ID和密钥访...

  • 云计算 | AWS | SQS

    简单队列服务: SQS SQS适用于微服务、分布式系统和无服务器应用程序的完全托管的消息队列,是Amazon为解决...

  • AWS SQS

    Basic The queue acts as a buffer between the component pr...

  • 使用SQS接收SES消息

    前提: 必须开通aws的3个服务:SES、SNS、SQS 业务流程: 1. SES将消息(发送、退回、投诉、拒收)...

  • STS/SNS/SQS TEST 知识点

    STS/SNS/SQS TEST 知识点 1 当使用者接收并处理来自某个队列的消息时,消息将保留在该队列中。Ama...

  • AWS SQS & MQ

    Amazon SQS Amazon SQS offers two queue types for differen...

  • AWS_Others

    Elastic Load Balancing 简介 入门 Amazon SQS 简介 标准队列 标准队列使您能够每...

  • 队列如何使用

    Laravel 队列为不同的后台队列服务提供统一的 API,例如 Beanstalk,Amazon SQS,Red...

  • Spring SqsListener异常处理

    在Spring里我们可以使用Spring Cloud AWS里的SqsListener方便地在后台持续接收SQS消...

网友评论

      本文标题:给aws sqs发队列消息

      本文链接:https://www.haomeiwen.com/subject/qgaxmqtx.html