- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在构建一个 rest api,它从其他 api 收集数据,用它做一些逻辑并发送回客户端:
我的主课:
public class Main {
public static void main(String[] args) {
Vertx.vertx().deployVerticle(RestVerticle.class.getName());
}
这是我的 RestVerticle:
public class RestVerticle extends AbstractVerticle {
public static final String API_V1 = "/api/v1";
private Map<String, JsonObject> products = new HashMap<>();
@Override
public void start() {
Router router = Router.router(vertx);
router.route().handler(BodyHandler.create());
router.get(API_V1 + "/business/all").handler(this::getAllBusinesses);
vertx.createHttpServer().requestHandler(router::accept).listen(8080);
}
private void getAllBusinesses(RoutingContext routingContext) {
vertx.deployVerticle(YelpClientVerticle.class.getName());
MessageConsumer<String> consumer = vertx.eventBus().consumer("api");
consumer.handler(message -> {
JsonObject m = new JsonObject((String) message.body());
System.out.println("Received message: " + message.body());
routingContext.response().putHeader("content-type", "application/json").end(m.encodePrettily());
});
}
这是我的 httpclient ,它调用 Yelp API:
public class YelpClientVerticle extends AbstractVerticle {
private static final String API_HOST = "api.yelp.com";
private static final String DEFAULT_TERM = "dinner";
private static final String DEFAULT_LOCATION = "San Francisco, CA";
private static final int SEARCH_LIMIT = 20;
private static final String SEARCH_PATH = "/v2/search";
private static final String BUSINESS_PATH = "/v2/business";
/*
* Update OAuth credentials below from the Yelp Developers API site:
* http://www.yelp.com/developers/getting_started/api_access
*/
private static final String CONSUMER_KEY = "XXXXX";
private static final String CONSUMER_SECRET = "XXXXX";
private static final String TOKEN = "XXXXX";
private static final String TOKEN_SECRET = "XXXXX";
OAuthService service;
Token accessToken;
/**
* Setup the Yelp API OAuth credentials.
*
* @param consumerKey Consumer key
* @param consumerSecret Consumer secret
* @param token Token
* @param tokenSecret Token secret
*/
/**
* Creates and sends a request to the Search API by term and location.
* <p>
* See <a href="http://www.yelp.com/developers/documentation/v2/search_api">Yelp Search API V2</a>
* for more info.
*
* @param term <tt>String</tt> of the search term to be queried
* @param location <tt>String</tt> of the location
* @return <tt>String</tt> JSON Response
*/
public String searchForBusinessesByLocation(String term, String location) {
OAuthRequest request = createOAuthRequest(SEARCH_PATH);
request.addQuerystringParameter("term", term);
request.addQuerystringParameter("location", location);
request.addQuerystringParameter("limit", String.valueOf(SEARCH_LIMIT));
return sendRequestAndGetResponse(request);
}
/**
* Creates and sends a request to the Business API by business ID.
* <p>
* See <a href="http://www.yelp.com/developers/documentation/v2/business">Yelp Business API V2</a>
* for more info.
*
* @param businessID <tt>String</tt> business ID of the requested business
* @return <tt>String</tt> JSON Response
*/
public String searchByBusinessId(String businessID) {
OAuthRequest request = createOAuthRequest(BUSINESS_PATH + "/" + businessID);
return sendRequestAndGetResponse(request);
}
/**
* Creates and returns an {@link OAuthRequest} based on the API endpoint specified.
*
* @param path API endpoint to be queried
* @return <tt>OAuthRequest</tt>
*/
private OAuthRequest createOAuthRequest(String path) {
OAuthRequest request = new OAuthRequest(Verb.GET, "https://" + API_HOST + path);
return request;
}
/**
* Sends an {@link OAuthRequest} and returns the {@link Response} body.
*
* @param request {@link OAuthRequest} corresponding to the API request
* @return <tt>String</tt> body of API response
*/
private String sendRequestAndGetResponse(OAuthRequest request) {
System.out.println("Querying " + request.getCompleteUrl() + " ...");
this.service.signRequest(this.accessToken, request);
Response response = request.send();
return response.getBody();
}
/**
* Queries the Search API based on the command line arguments and takes the first result to query
* the Business API.
*
* @param yelpApiCli <tt>YelpAPICLI</tt> command line arguments
*/
private String queryAPI(YelpAPICLI yelpApiCli) {
String searchResponseJSON =
searchForBusinessesByLocation(yelpApiCli.term, yelpApiCli.location);
JSONParser parser = new JSONParser();
JSONObject response = null;
try {
response = (JSONObject) parser.parse(searchResponseJSON);
} catch (ParseException pe) {
System.out.println("Error: could not parse JSON response:");
System.out.println(searchResponseJSON);
System.exit(1);
}
JSONArray businesses = (JSONArray) response.get("businesses");
JSONObject firstBusiness = (JSONObject) businesses.get(0);
String firstBusinessID = firstBusiness.get("id").toString();
System.out.println(String.format(
"%s businesses found, querying business info for the top result \"%s\" ...",
businesses.size(), firstBusinessID));
// Select the first business and display business details
String businessResponseJSON = searchByBusinessId(firstBusinessID.toString());
System.out.println(String.format("Result for business \"%s\" found:", firstBusinessID));
System.out.println(businessResponseJSON);
return businessResponseJSON;
}
/**
* Command-line interface for the sample Yelp API runner.
*/
private static class YelpAPICLI {
@Parameter(names = {"-q", "--term"}, description = "Search Query Term")
public String term = DEFAULT_TERM;
@Parameter(names = {"-l", "--location"}, description = "Location to be Queried")
public String location = DEFAULT_LOCATION;
}
@Override
public void start() throws Exception {
// Note! in real-life you wouldn't often set trust all to true as it could leave you open to man in the middle attacks.
this.service =
new ServiceBuilder().provider(TwoStepOAuth.class).apiKey(CONSUMER_KEY)
.apiSecret(CONSUMER_SECRET).build();
this.accessToken = new Token(TOKEN, TOKEN_SECRET);
YelpAPICLI yelpApiCli = new YelpAPICLI();
new JCommander(yelpApiCli);
String response = queryAPI(yelpApiCli);
vertx.eventBus().send("api", response);
}
我遇到了 2 个问题。
第一个问题是 Yelp 客户端处理请求的时间太长,它阻塞了主线程并发出警告:
Jan 04, 2016 1:34:30 AM io.vertx.core.impl.BlockedThreadChecker
WARNING: Thread Thread[vert.x-eventloop-thread-4,5,main] has been blocked for 3151 ms, time limit is 2000
第二个问题是,在处理完第一个请求后,例如,我第一次访问我的 localhost:8080/api/v1/business/all ,请求成功返回,但下一次再次点击 URL时间,它抛出这样的异常:
Jan 04, 2016 1:34:30 AM io.vertx.core.eventbus.impl.HandlerRegistration
SEVERE: Failed to handleMessage
java.lang.IllegalStateException: Response has already been written
我该如何解决这两个问题?
最佳答案
问题是您在每个 请求时都在做所有工作——启动 Yelp Verticle,并在事件总线上注册消费者。这不可能是你想要的。
所以,我认为正在发生的事情:
getAllBusinesses()
方法被执行。YelpClientVerticle
。api
端点上注册,它将写入响应。 YelpClientVerticle
做了很多阻塞工作 - 这就是您收到 BlockedThreadChecker
警告的原因。 最后,Yelp 请求返回并通过事件总线发送一条消息,然后该消息被写入响应。
您提出另一个请求
转到 2
您的问题是,对于每个请求,您都会启动另一个 YelpClientVerticle
,并注册另一个处理程序来监听相同 EventBus
端点地址。
让多个处理程序监听同一个 EventBus 地址
是完全可以接受的。发生这种情况时,Vert.x
会以 RoundRobin
方式选择其中一个处理程序。
我猜测在第二个请求 中,Vertx
正在选择第一个处理程序,并尝试写入您已经写入的第一个请求的响应。因此错误。
我会尝试将 YelpClientVerticle
的部署移动到 RestVerticle
的启动中 - 那么您将只有一个实例。
您可能想要切换发送者/消费者,因此您发送
一条消息到 YelpClientVerticle
,然后它会回复。
您可能还想阅读有关 Running Blocking Code 的文档,因为您的 Yelp 客户端看起来正在阻塞。
希望对你有帮助
关于java - 顶点抛出 IllegalStateException : Response has already been written,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34580170/
我想使用图中所示的迷宫,使用迭代深度优先搜索找到从起始节点到目标的路径。它是一个仅包含一对数字的文本文件,例如成对连接,又称边/弧。像这样: 11 3 2 3 0 3 1 4 5 4 5 7 6 7
问题:您有一个无向图 G = (V, E)(V = 顶点,E = 边),您必须访问每个顶点并在两个方向上通过每个边。 我所知道的图算法只有 DFS、BFS 和一些 MST(Kruskal 等)不幸的是
枚举任意图中两个顶点之间的所有简单路径通常需要指数时间,因为顶点之间可能存在指数数量的简单路径。但是,如果我们只对位于两个末端顶点之间的至少一条简单路径上的顶点怎么办? 即:给定一个无向图和两个不同的
我正在开发一个简单的 opengl 游戏以了解更多相关信息。但是由于某种原因,当我尝试随时间旋转我的立方体时,它会被拉伸(stretch)。你可以在照片中看到它: 我认为这与我的模型矩阵有关,但我不确
我已经在谷歌上搜索了很长一段时间,但我找不到任何东西。如何使用 Graphviz 绘制没有连接顶点的图形? 最佳答案 像这样: digraph g { SingleNode; } 简单地不定义
我目前正在使用 R 中的“igraph”包进行一些社交网络分析,我想知道是否有一种方法可以个性化社交网络中节点的放置。 例如,使用以下玩具代码: library(igraph) edg
我在 Box2D 中有一个多边形形状。形状是一个三角形,我希望有 3 个顶点。事实上,我创建的所有形状都会输出 8 个顶点。为什么是这样?如果我输出顶点数,那总是正确的数量。我不想渲染不必要的线条,但
来自user manual CGAL Surface_mesh 类: the data structure uses integer indices as descriptors for vertic
我正在尝试找到引用 ARFaceGeometry 网格索引的方法为了使用 ARKit 将图形放置在面部的特定部位。 我见过很多例子,其中功能与一些索引号,但我找不到对此列表的任何引用。它似乎有超过12
Apache TomCat(版本未知) 业务对象 4.1 顶点 4.4.3 在一台服务器上,我们拥有 TomCat 和 Business Objects。 APEX 也使用 TomCat。 在对我们的
我正在使用 MX Graph 进行一些工作,以帮助识别网站中的关键内容路径。我将其设置为每个顶点代表网站上的一个页面,每条边代表一组从页面 A 访问页面 B 的访问者。 一切都运行良好,除了边太多,我
我正在尝试使用三角形 strip 绘制一个平面。我了解如何手动执行此操作,但我真的很难使用 for 循环来执行此操作。到目前为止,下面的代码绘制了两个三角形。 //vertices for trian
如果我想通过 id 顶点获取名称,我可以使用这个函数:VAS(g, "name",id)但是如果我想要相反的方式,通过名称获取 id,我该怎么做呢? 最佳答案 igraph 本身不提供按名称查找顶点的
我有一个三角形,其任意顶点位于 3D 空间中。 我知道通过以下操作很容易找到这种三角形的质心: float centroid[3] = { 0, 0, 0 }; for (int i = 0; i =
我有一个点数组。每个点都有位置(x, y, z) 和法 vector (xn, yn, zn) ,一共6个 double 。考虑到浮点容差,我需要在此数组中找到唯一元素并删除重复条目。 实现它的简单有
我有一个相互连接的边列表 (E),如何找到从一个顶点连接到另一个顶点的最短路径? 我正在考虑使用 lowest common ancestors ,但边缘没有明确定义的根,所以我认为该解决方案不起作用
我现在正在使用计算着色器开发粒子系统。我将所有粒子都放在着色器存储缓冲区中。一个粒子包含两个顶点,当前位置和先前位置。 struct Particle{ glm::vec4 _currPo
我将我的顶点剪裁在边缘上,如这张专辑所示: http://imgur.com/a/VkCrJ 当我的地形大小为 400 x 400 时,我得到裁剪,但在 40x40 或更小时,我没有得到任何裁剪。这是
总是在顶点着色器中而不是在片段着色器中更好地进行硬计算吗?即使是具有超过 100.000 个多边形的高网格模型(假设有一堆独特的顶点)? 最佳答案 不,它并不总是更好。 选择合适的计算位置的最佳方法是
我想编辑一个立方体上的 1 个顶点,但我不知道该怎么做。我试过到处寻找此功能,但找不到解决方案。 这是我想要实现的目标的图像: 最佳答案 http://answers.unity3d.com/ques
我是一名优秀的程序员,十分优秀!