首先我们需要知道的是,url是要符合一定格式的,比如我们就不能在url中写“$”、“#”、中文、空格等。所以,我们这里采用application/x-www-form-urlencoded格式对请求参数进行编码,可参考如下代码:
/**
* 构造完整请求url(带参数)
* @param url 请求url,形如:http://192.168.1.19
* @param params 请求参数,key是参数名,value是参数值
* @return 构造好的url,形如:http://192.168.1.19?name=mark&base=jinan
*/
public static String buildUrl(String url, Map<String, String> params) throws UnsupportedEncodingException {
StringBuilder urlBuilder = new StringBuilder(url);
if (params != null) {
Set<String> keySet = params.keySet();
if (CollectionUtils.isNotEmpty(keySet)) {
urlBuilder.append("?");
for (String key : keySet) {
urlBuilder.append(key)
.append("=")
.append(URLEncoder.encode(params.get(key), StandardCharsets.UTF_8.name()))
.append("&");
}
urlBuilder.deleteCharAt(urlBuilder.length() - 1);
}
}
return urlBuilder.toString();
}
通过方法buildUrl,我们就完成了url的拼接工作。
“采用application/x-www-form-urlencoded格式对请求参数进行编码”,到底是什么意思呢?
首先我们可以先搞懂URLEncoder.encode(params.get(key), StandardCharsets.UTF_8.name())方法的第二个参数的作用是什么
String str = new String(charArrayWriter.toCharArray());
byte[] ba = str.getBytes(charset);
上面代码片段摘自URLEncoder的encode方法,charArrayWriter.toCharArray()是待编码字符串的字符数组,charset就是我们传入的“utf-8”。可以看出来,这里首先是将待编码字符串使用“utf-8”进行编码。当然这里也可以根据具体的需求,采用其他的编码格式。
紧接着,再继续对经过“utf-8”编码后的字符串,采用application/x-www-form-urlencoded编码格式要求进行计算,相关算法源码如下:
String str = new String(charArrayWriter.toCharArray());
byte[] ba = str.getBytes(charset);
for (int j = 0; j < ba.length; j++) {
out.append('%');
char ch = Character.forDigit((ba[j] >> 4) & 0xF, 16);
// converting to use uppercase letter as part of
// the hex value if ch is a letter.
if (Character.isLetter(ch)) {
ch -= caseDiff;
}
out.append(ch);
ch = Character.forDigit(ba[j] & 0xF, 16);
if (Character.isLetter(ch)) {
ch -= caseDiff;
}
out.append(ch);
}
总结一下,URLEncoder.encode(params.get(key), StandardCharsets.UTF_8.name())做了两件事:首先将待编码字符串使用“utf-8”进行编码;然后将编码结果再使用符合application/x-www-form-urlencoded编码格式要求进行计算。经过以上两步,就完成了对字符串的编码工作。
发起请求后,返回的结果是一个InputStream,使用下面的代码读取它:
/**
* 读取InputStream
*/
private static String getContent(InputStream inputStream) throws IOException {
try (BufferedReader bufferedReader = new BufferedReader(
new InputStreamReader(inputStream, StandardCharsets.UTF_8.name()))) {
String line;
StringBuilder result = new StringBuilder();
while ((line = bufferedReader.readLine()) != null) {
result.append(line);
}
return result.toString();
}
}
注意,对于BufferedReader、InputStreamReader、InputStream三个流,只需要关闭最外层的即可,流会一层一层的向内关闭,我们可以看下BufferedReader的close方法源码:
public void close() throws IOException {
synchronized (lock) {
if (in == null)
return;
try {
in.close();
} finally {
in = null;
cb = null;
}
}
}
这里的in变量,实际上就对应咱们代码里的InputStreamReader,然后InputStreamReader调用close方法时,会继续向内关闭。
那么您可能也要问了,getContent方法有关闭任何流的代码么,为什么我没看见?其实是这样的,因为BufferedReader实现了Closeable接口,那么只需要把BufferedReader方法写到try代码块里,java就会自动帮助我们关闭的。
java原生api支持发起get请求,示例代码如下:
/**
* 发起GET请求(使用java原生方法)
* @param url 请求路径
* @param params 请求参数
* @param headers 请求头
*/
public static String doGet(String url, Map<String, String> params, Map<String, String> headers) throws Exception {
// 1.构造完整请求url(带参数)
String fullUrl = buildUrl(url, params);
log.info("full url is: " + fullUrl);
// 2.打开连接
HttpURLConnection conn = (HttpURLConnection) new URL(fullUrl).openConnection();
// 3.设置请求方法为get
conn.setRequestMethod("GET");
// 4.设置请求头
if (headers != null) {
Set<String> headerKeys = headers.keySet();
if (CollectionUtils.isNotEmpty(headerKeys)) {
for (String headerKey : headerKeys) {
conn.setRequestProperty(headerKey, headers.get(headerKey));
}
}
}
// 5.获取响应状态码(非2开头状态码,认定请求失败)
int statusCode = conn.getResponseCode();
if (statusCode < HttpStatus.SC_OK || statusCode >= HttpStatus.SC_MULTIPLE_CHOICES) {
log.error("status code is: " + statusCode);
log.error("error message is: " + getContent(conn.getErrorStream()));
throw new Exception("response status code wrong, status code is: " + statusCode);
}
// 6.获取请求结果
return getContent(conn.getInputStream());
}
apache也提供了工具包,示例代码如下:
/**
* 发起GET请求(使用apache的HttpClient)
* @param url 请求路径
* @param params 请求参数
* @param headers 请求头
*/
public static String doGetByHttpClient(String url, Map<String, String> params, Map<String, String> headers) throws Exception {
try (CloseableHttpClient client = HttpClients.createDefault()) {
// 1.构造完整请求url(带参数)
String fullUrl = buildUrl(url, params);
log.info("full url is: " + fullUrl);
// 2.创建httpGet
HttpGet httpGet = new HttpGet(fullUrl);
// 3.设置请求头
if (headers != null) {
Set<String> headerKeys = headers.keySet();
if (CollectionUtils.isNotEmpty(headerKeys)) {
for (String headerKey : headerKeys) {
httpGet.setHeader(headerKey, headers.get(headerKey));
}
}
}
// 4.发起请求
CloseableHttpResponse response = client.execute(httpGet);
// 5.获取响应状态码(非2开头状态码,认定请求失败)
StatusLine statusLine = response.getStatusLine();
int statusCode = statusLine.getStatusCode();
if (statusCode < HttpStatus.SC_OK || statusCode >= HttpStatus.SC_MULTIPLE_CHOICES) {
log.error("status code is: " + statusCode);
log.error("error message is: " + statusLine.getReasonPhrase());
throw new Exception("response status code wrong, status code is: " + statusCode);
}
// 6.获取请求结果
return getContent(response.getEntity().getContent());
}
}
就我写以上代码的经验来看,使用原生的或者httpClient,差别不大,我个人反而更喜欢原生的。各位大佬看自己喜好吧。
我正在尝试设置一个puppet节点,但rubygems似乎不正常。如果我通过它自己的二进制文件(/usr/lib/ruby/gems/1.8/gems/facter-1.5.8/bin/facter)在cli上运行facter,它工作正常,但如果我通过由rubygems(/usr/bin/facter)安装的二进制文件,它抛出:/usr/lib/ruby/1.8/facter/uptime.rb:11:undefinedmethod`get_uptime'forFacter::Util::Uptime:Module(NoMethodError)from/usr/lib/ruby
在我的Controller中,我通过以下方式在我的index方法中支持HTML和JSON:respond_todo|format|format.htmlformat.json{renderjson:@user}end在浏览器中拉起它时,它会自然地以HTML呈现。但是,当我对/user资源进行内容类型为application/json的curl调用时(因为它是索引方法),我仍然将HTML作为响应。如何获取JSON作为响应?我还需要说明什么? 最佳答案 您应该将.json附加到请求的url,提供的格式在routes.rb的路径中定义。这
我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么? 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设? 关于java-等价于Java中的RubyHash,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/22737685/
rails中是否有任何规定允许站点的所有AJAXPOST请求在没有authenticity_token的情况下通过?我有一个调用Controller方法的JqueryPOSTajax调用,但我没有在其中放置任何真实性代码,但调用成功。我的ApplicationController确实有'request_forgery_protection'并且我已经改变了config.action_controller.consider_all_requests_local在我的environments/development.rb中为false我还搜索了我的代码以确保我没有重载ajaxSend来发送
我正在尝试使用boilerpipe来自JRuby。我看过guide从JRuby调用Java,并成功地将它与另一个Java包一起使用,但无法弄清楚为什么同样的东西不能用于boilerpipe。我正在尝试基本上从JRuby中执行与此Java等效的操作:URLurl=newURL("http://www.example.com/some-location/index.html");Stringtext=ArticleExtractor.INSTANCE.getText(url);在JRuby中试过这个:require'java'url=java.net.URL.new("http://www
我只想对我一直在思考的这个问题有其他意见,例如我有classuser_controller和classuserclassUserattr_accessor:name,:usernameendclassUserController//dosomethingaboutanythingaboutusersend问题是我的User类中是否应该有逻辑user=User.newuser.do_something(user1)oritshouldbeuser_controller=UserController.newuser_controller.do_something(user1,user2)我
什么是ruby的rack或python的Java的wsgi?还有一个路由库。 最佳答案 来自Python标准PEP333:Bycontrast,althoughJavahasjustasmanywebapplicationframeworksavailable,Java's"servlet"APImakesitpossibleforapplicationswrittenwithanyJavawebapplicationframeworktoruninanywebserverthatsupportstheservletAPI.ht
这篇文章是继上一篇文章“Observability:从零开始创建Java微服务并监控它(一)”的续篇。在上一篇文章中,我们讲述了如何创建一个Javaweb应用,并使用Filebeat来收集应用所生成的日志。在今天的文章中,我来详述如何收集应用的指标,使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值,然后一切都回到一个请求。这也意味着这些指标可能不准确,你还想提取最小/
HashMap中为什么引入红黑树,而不是AVL树呢1.概述开始学习这个知识点之前我们需要知道,在JDK1.8以及之前,针对HashMap有什么不同。JDK1.7的时候,HashMap的底层实现是数组+链表JDK1.8的时候,HashMap的底层实现是数组+链表+红黑树我们要思考一个问题,为什么要从链表转为红黑树呢。首先先让我们了解下链表有什么不好???2.链表上述的截图其实就是链表的结构,我们来看下链表的增删改查的时间复杂度增:因为链表不是线性结构,所以每次添加的时候,只需要移动一个节点,所以可以理解为复杂度是N(1)删:算法时间复杂度跟增保持一致查:既然是非线性结构,所以查询某一个节点的时候
1.错误信息:Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:requestcanceledwhilewaitingforconnection(Client.Timeoutexceededwhileawaitingheaders)或者:Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:TLShandshaketimeout2.报错原因:docker使用的镜像网址默认为国外,下载容易超时,需要修改成国内镜像地址(首先阿里