在 Rabbitmq 中发送一个 Sh 文件
Send a Sh file in Rabbitmq
我是 rabbitmq 的新手,我想在 rabbitmq 中发送一个 .sh 文件。我已经设置了我的队列和交换。我正在使用 spring-amqp,我可以使用我的监听器容器
发送 json 消息
public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
container.setQueues(topicQueue());
container.setAcknowledgeMode(AcknowledgeMode.AUTO);
container.setMessageListener(new MessageListenerAdapter(pageListener(), jsonMessageConverter()));
return container;
}
但我不确定如何发送 sh 文件并将其写入我的页面监听器。知道怎么做吗?
您需要阅读文件并发送内容。
您可以使用 SimpleMessageConverter
(默认值),如果 content_type
属性 是 text/plain
,您将得到一个字符串;否则你会得到 byte[]
.
在接收方(大概),您必须将其写入文件并设置权限。
我是 rabbitmq 的新手,我想在 rabbitmq 中发送一个 .sh 文件。我已经设置了我的队列和交换。我正在使用 spring-amqp,我可以使用我的监听器容器
发送 json 消息public SimpleMessageListenerContainer messageListenerContainer() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
container.setQueues(topicQueue());
container.setAcknowledgeMode(AcknowledgeMode.AUTO);
container.setMessageListener(new MessageListenerAdapter(pageListener(), jsonMessageConverter()));
return container;
}
但我不确定如何发送 sh 文件并将其写入我的页面监听器。知道怎么做吗?
您需要阅读文件并发送内容。
您可以使用 SimpleMessageConverter
(默认值),如果 content_type
属性 是 text/plain
,您将得到一个字符串;否则你会得到 byte[]
.
在接收方(大概),您必须将其写入文件并设置权限。