gpt4 book ai didi

java - ActiveMQ 通过 REST 处理消息

转载 作者:行者123 更新时间:2023-12-01 10:36:14 24 4
gpt4 key购买 nike

我是 ActiveMQ 的新手,我们在其他位置有一个 ActiveMQ 服务器,我们无法通过 tcp 套接字连接,但能够使用 REST 命令获取消息

http://admin:admin@localhost:8161/api/message?destination=queue://orders.input

我在 ActiveMQ 中有超过 99K 条消息,需要使用 REST 命令使用并需要存储在文本文件中,

import static com.jayway.restassured.RestAssured.given;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.URI;
import java.net.URISyntaxException;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import org.apache.commons.codec.binary.Base64;
import org.apache.http.HttpRequest;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;

import com.dnb.e2e.automation.util.CommonUtil;
import com.dnb.e2e.automation.util.WebServiceUtil;
import com.jayway.restassured.RestAssured;
import com.jayway.restassured.config.SSLConfig;
import com.jayway.restassured.config.SessionConfig;
import com.jayway.restassured.response.Headers;
public class MQwithRest {
public static String getResponse() throws Exception
{
String url = "http://admin:admin@localhost:8161/api/message?destination=queue://SAMPLEQUEUE";

String response = "a";

while(response!=""){
try {
response = given().header("content-type", "application/json")
.request()
.config(RestAssured.config().sslConfig(new SSLConfig().allowAllHostnames()))
.when().get(url).asString();
System.out.println(response);
} catch (Exception e) {
e.printStackTrace();
}
}
return "empty";
}

public static void main(String args[]) throws Exception
{
System.out.println(MQwithRest.getResponse());
}
}

在上面的代码中,我在输出端显示消耗的消息。当我通过休息实现时,每个 session 一次只能使用一条消息。

任何机构都可以帮助使用 REST 服务在单个 session 中消耗 99k+ 消息吗?

最佳答案

您还可以隧道 JMS client over HTTP 。这样,您就可以绕过网络中的任何非 HTTP 限制,并且仍然使用 JMS 术语。

使用捆绑的其余 Web 应用程序,您在检索消息的语义上会受到一些限制。无论如何,您应该能够使用纯 HTTP/Rest 获取所有消息。只需使用循环即可获取消息。

关于java - ActiveMQ 通过 REST 处理消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34708249/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com