小编Roy*_*ger的帖子

我可以向 AWS SNS 发送批处理消息吗

我正在开发一个应用程序,我需要在其中向 SNS 发送多个事件。有没有办法批量发送所有事件,或者我是否需要使用for循环(我使用Java)一个一个地发送/发布到SNS。

amazon-sqs amazon-web-services amazon-sns

5
推荐指数
2
解决办法
4063
查看次数

瞬态变量能否以任何方式序列化?

我在接受采访时遇到了这个问题.请帮我找到答案.问题是瞬态变量能否以任何方式序列化?

java

4
推荐指数
1
解决办法
381
查看次数

setHeader()如何在Apache驼峰中运行

我正在阅读有关Apache Camel的一些文档,但无法理解setHeader()Apache Camel中的内容.它是否为其中指定的文件添加标头from.并建议一些链接,我可以获得有关Apache Camel的教程.

java apache-camel

2
推荐指数
2
解决办法
1万
查看次数

从 SQS 接收的消息数量是否限制为每个批处理调用 10 个

我正在开发一个使用 Amazon SQS 的应用程序。我是 AWS 的新手,所以我对从 SQS 接收消息有一点疑问。我已经配置了一个 SQS,并希望通过使用长轮询来接收来自它的消息。我的问题是我最多可以从 SQS 获得多少条消息?

我已将 设置MaxNumberOfMessages为 50 和ReceiveMessageWaitTimeSeconds20。

一季度。我最多可以从 SQS 获得 50 条消息吗?

Q2。有ReceiveMessageWaitTimeSeconds什么关系?我在 AWS 文档中读到短轮询= 0 sec和长轮询的时间超过 0 秒。这是否意味着我也可以设置ReceiveMessageWaitTimeSeconds = 5以确保长轮询?

我还阅读了短轮询和长轮询之间的区别,因为前者只会查询 SQS 服务器的一个子集,而后者会查询所有服务器。那么除了它会等待 5 秒或 20 秒之外,秒是否重要?

我已经浏览了以下 AWS 文档:

示例代码如下:

CreateQueueRequest createQueueRequest = new CreateQueueRequest().withQueueName(queueName);
 String queueUrl = sqs.createQueue(createQueueRequest).getQueueUrl();
 ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(queueUrl);
 receiveMessageRequest.setMaxNumberOfMessages(50);
 receiveMessageRequest.setReceiveMessageWaitTimeSeconds(20);
 List<Message> messages = …
Run Code Online (Sandbox Code Playgroud)

java amazon-sqs amazon-web-services

2
推荐指数
1
解决办法
3262
查看次数

我可以将 Map&lt;String, List&lt;Integer&gt;&gt; 转换为 MultiValueMap&lt;String, Integer&gt;

我正在尝试将地图转换为多值地图,但出现以下编译异常:

Wrong 1st argument type. Found: java.util.Map<java.lang.String,java.util.List<java.lang.String>>, required: org.springframework.util.MultiValueMap<java.lang.String,java.lang.String> less... Inspection info:

这是结构: Map<String, List<String>> tradersTradeMap-> MultiValueMap<String, String>tradersTradeMap

class Trade {

  public String getTraderNameAfterProcesing (MultiValueMap<String, String> 
      tradersTradeMap){
      ..... // SOme code goes here
   }

}

class Customer {

private Trade trade;

public String Method1(){
   Map<String, List<String>> traderTradeMap = new HashMap<>();
   traderTradeMap.put("TraderA", Arrays.asList("SPOT","BLOCK","FORWARD"));
   traderTradeMap.put("TraderB", Arrays.asList("SPOT","BLOCK"));

   trade = new Trade();
   trade.getTraderNameAfterProcesing(traderTradeMap); // This line is giving exception 

}

}
Run Code Online (Sandbox Code Playgroud)

有什么简单的方法可以做到吗?

java spring

1
推荐指数
2
解决办法
1万
查看次数