• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java HttpRequest类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.github.kevinsawicki.http.HttpRequest的典型用法代码示例。如果您正苦于以下问题:Java HttpRequest类的具体用法?Java HttpRequest怎么用?Java HttpRequest使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



HttpRequest类属于com.github.kevinsawicki.http包,在下文中一共展示了HttpRequest类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: main

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
public static void main(String[] args) {
	ExecutorService pool = Executors.newFixedThreadPool(50);
	for(int i=0;i<50;i++){
		pool.execute(new Runnable() {
			@Override
			public void run() {
				while(true){
					Map<String, String> data = new HashMap<String, String>();
					data.put("q", "SELECT MAX(value) FROM sensor where device_code='d_bt_0' and sensor_code='s_btg_8' and time>=1485541192230000000 and time<=1485627592230000000");
					HttpRequest.post("http://10.77.110.226:8086/query?db=ruc_test1").form(data).code();
				}
			}
		});
	}
	try {
		pool.awaitTermination(Long.MAX_VALUE,TimeUnit.DAYS);
	} catch (InterruptedException e) {
		e.printStackTrace();
	}
}
 
开发者ID:dbiir,项目名称:ts-benchmark,代码行数:21,代码来源:HttpRequestTest.java


示例2: doGet

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
		throws ServletException, IOException {
	
	String token = AuthConfig.getToken();
	Long user_id=AuthConfig.getUser_id();
	OutputStream os = resp.getOutputStream();
	
	if (token!=null&&user_id>0) {
		Map<String, String> data = new HashMap<String, String>();
		data.put("token", token);
		data.put("user_id", user_id.toString());
		
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
		
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:21,代码来源:GetAllTextsServlet.java


示例3: post

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
/**
 * 构造POST提交表单请求,返回响应结果
 * @param params
 * 提交的参数
 * @param address
 * 提交的地址
 * @param connectTimeout
 * @param readTimeout
 * @return
 */
public static HttpResult post(Map<String,String> params,String address,int connectTimeout,int readTimeout) throws IOException {
    HttpResult result = new HttpResult();
    if(params == null){
        params = new HashMap<>();
    }
    if(StringUtils.isEmpty(address)){
        log.error("请求地址不能为空");
        return null;
    }
    URL requestUrl = new URL(address);
    long start = System.currentTimeMillis();
    HttpRequest httpRequest = new HttpRequest(requestUrl,"POST")
            .connectTimeout(connectTimeout).readTimeout(readTimeout).trustAllCerts().trustAllHosts();
    httpRequest.form(params,"UTF-8");
    result.setStatus(httpRequest.code());
    result.setResult(httpRequest.body());
    result.setResponseTime(System.currentTimeMillis() - start);
    return result;
}
 
开发者ID:DevopsJK,项目名称:SuitAgent,代码行数:30,代码来源:HttpUtil.java


示例4: insert

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
private Status insert(String data) {
	HttpRequest hr = null;
	long costTime = 0L;
	try {
		hr = HttpRequest.post(WRITE_URL).connectTimeout(100 * 1000).readTimeout(100 * 1000);
		long startTime = System.nanoTime();
		hr.send(data);
		hr.code();
		long endTime = System.nanoTime();
		costTime = endTime - startTime;
	} catch (Exception e) {
		e.printStackTrace();
		return Status.FAILED(-1);
	}
	System.out.println(hr.body());
	if (hr.code() >= 200 && hr.code() < 300) {
		return Status.OK(costTime);
	} else {
		return Status.FAILED(costTime);
	}
}
 
开发者ID:dbiir,项目名称:ts-benchmark,代码行数:22,代码来源:InfluxDB.java


示例5: getOpenIdByCode

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
/**
 * Warning: This function need to visit weixin websites
 *
 * @return
 */
public static String getOpenIdByCode(String code) {
    Map<String, String> params = new HashMap<String, String>();
    params.put("appid", Const.WX_APP_ID);
    params.put("secret", Const.WX_APP_SECRET);
    params.put("code", code);
    params.put("grant_type", "authorization_code");
    String body = HttpRequest.get("https://api.weixin.qq.com/sns/oauth2/access_token", params, true).body();

    Map result = JSON.parseObject(body, Map.class);
    String openId = (String) result.get("openid");
    if (openId == null) {
        logger.error(body);
    }
    return openId;
}
 
开发者ID:luckyyeah,项目名称:YiDu-Novel,代码行数:21,代码来源:WeixinUtils.java


示例6: getAccessTokenByCode

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
/**
 * Warning: This function need to visit weixin websites
 *
 * @return
 */
public static Map getAccessTokenByCode(String code) {
    Map<String, String> params = new HashMap<String, String>();
    params.put("appid", Const.WX_APP_ID);
    params.put("secret", Const.WX_APP_SECRET);
    params.put("code", code);
    params.put("grant_type", "authorization_code");
    String body = HttpRequest.get("https://api.weixin.qq.com/sns/oauth2/access_token", params, true).body();

    Map result = JSON.parseObject(body, Map.class);
    String access_token = (String) result.get("access_token");
    if (access_token == null) {
        logger.error(body);
    }
    return result;
}
 
开发者ID:luckyyeah,项目名称:YiDu-Novel,代码行数:21,代码来源:WeixinUtils.java


示例7: createIndex

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
public void createIndex(String indexName, String indexJson) {
    if (esHost == null) {
        log.warn("ES host not set as system property");
        return;
    }
    log.info("checking if the search index exists for name: " + indexName);
    int responseCode = HttpRequest.get("http://" + esHost + ":9200/" + indexName).code();
    if (responseCode != 404) {
        log.info("index already setup");
        return;
    }
    log.info("Creating search index with name: " + indexName);
    String response = HttpRequest.put("http://" + esHost
            + ":9200/" + indexName)
            .contentType("application/json").send(indexJson)
                    .body();
}
 
开发者ID:oneops,项目名称:oneops,代码行数:18,代码来源:SearchDal.java


示例8: main

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
public static void main(String args[]) throws Exception {
		Map<String, String> data = new HashMap<String, String>();
		
		// 公钥加密过程
//		String plainText = "{\"username\":\"test\",\"password\":\"123456\"}";
//		byte[] cipherData = RSAEncrypt.encrypt(GlobalRSAKey.RSAPublicKey,
//				plainText.getBytes());
//		String cipher = Base64.encode(cipherData);
//		data.put("ciphertext", cipher);
//		String resultStr = HttpRequest.post("http://127.0.0.1:8080/auth.cgi")
//				.form(data).body();
//		
//		//解密前数据
//		System.out.println(resultStr);
		
		data.put("token","12d3s");
		data.put("user_id", "1");
		String resultStr =  HttpRequest.post("http://127.0.0.1:8080/token.cgi").form(data).body();
		
		//解密后的数据
		byte[] res = RSAEncrypt.decrypt(GlobalRSAKey.RSAPublicKey, Base64.decode(resultStr));
		String restr = new String(res);
		System.out.println(restr);
	}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:25,代码来源:SecurityMainTest.java


示例9: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
	String group_id=req.getParameter("group_id");
	String token = AuthConfig.getToken();
	Long userid=AuthConfig.getUser_id();
	
	OutputStream os = resp.getOutputStream();
	//OperationBean respBean = new OperationBean();
	
	
	if ( group_id!=null && userid!=null) {

			Map<String, String> data = new HashMap<String, String>();
			data.put("user_id", userid.toString());
			data.put("token", token);
			data.put("group_id", group_id);
			String returnAnswer = HttpRequest.post(authUrl).form(data).body();
			os.write(returnAnswer.getBytes("UTF-8"));
			// 返回给前端
	}
	os.flush();
	os.close();

}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:25,代码来源:DeteleGroupServlet.java


示例10: doGet

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
	Long userid=AuthConfig.getUser_id();
	String token=AuthConfig.getToken();
	
	OutputStream os=resp.getOutputStream();
	
	if (userid!=null && token!=null) {
		Map<String, String> data = new HashMap<String, String>();
		data.put("user_id", userid.toString());
		data.put("token", token);
		String returnAnswer = HttpRequest.get(authUrl+"?user_id="+userid+"&token="+token).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	} else {
		OperationBean respBean = new OperationBean();
		respBean.setCode(100);
		respBean.setMsg("token出错或userid出错");
		respBean.setRedirect(null);
		os.write(JsonUtil.beanToJson(respBean).getBytes("UTF-8"));
	}
	os.flush();
	os.close();


}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:26,代码来源:GetAllGroupsServlet.java


示例11: doGet

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
		throws ServletException, IOException {
	Long userid = AuthConfig.getUser_id();
	String token = AuthConfig.getToken();
	OutputStream os = resp.getOutputStream();
	
	if (userid != null && token != null) {
		Map<String, String> data = new HashMap<String, String>();
		data.put("user_id", userid.toString());
		data.put("token", token);
		String returnAnswer = HttpRequest.get(authUrl+"?user_id="+userid+"&token="+token).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	} else {
		OperationBean respBean = new OperationBean();
		respBean.setCode(100);
		respBean.setMsg("token出错或userid出错");
		respBean.setRedirect(null);
		os.write(JsonUtil.beanToJson(respBean).getBytes("UTF-8"));
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:24,代码来源:GetGroupsServlet.java


示例12: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
	String group_id=req.getParameter("group_id");
	String user_id=req.getParameter("user_id");
	String token=AuthConfig.getToken();
	
	OutputStream os=resp.getOutputStream();
	if (group_id!=null&&user_id!=null&&token!=null) {
		Map<String, String> data=new HashMap<String,String>();
		
		data.put("group_id", group_id);
		data.put("user_id", user_id);
		data.put("token", token);
		
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:21,代码来源:DeteleTextGroupServlet.java


示例13: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
	String user_id_str = req.getParameter("user_id");
	String name = req.getParameter("name");
	String token=AuthConfig.getToken();
	
	OutputStream os = resp.getOutputStream();

	if (user_id_str!=null&&name!=null&&token!=null) {
		Map<String, String> data=new HashMap<String,String>();
		data.put("user_id", user_id_str);
		data.put("name", name);
		data.put("token", token);
		
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:21,代码来源:AddTextGroupServlet.java


示例14: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
	String name = req.getParameter("name");
	String group_id_str = req.getParameter("group_id");
	String token=AuthConfig.getToken();
	
	OutputStream os = resp.getOutputStream();
	
	if (name!=null&&group_id_str!=null&&token!=null) {
		Map<String, String> data=new HashMap<String,String>();
		data.put("name", name);
		data.put("groud_id", group_id_str);
		data.put("token", token);
		 
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
	
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:22,代码来源:UpdateGroupNameSerlvet.java


示例15: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) 
		throws ServletException, IOException {
	
	String token = AuthConfig.getToken();
	String text_id=req.getParameter("text_id");
	OutputStream os = resp.getOutputStream();
	
	if (token!=null&&text_id!=null) {
		Map<String, String> data = new HashMap<String, String>();
		data.put("token", token);
		data.put("text_id", text_id);
		
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:20,代码来源:DeteleTextServlet.java


示例16: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) 
		throws ServletException, IOException {
	String group_id_str = req.getParameter("group_id");
	String text=req.getParameter("text");
	Long user_id=AuthConfig.getUser_id();
	String token=AuthConfig.getToken();
	
	OutputStream os=resp.getOutputStream();
	OperationBean respBean=new OperationBean();
	if (group_id_str!=null&&text!=null&&user_id>0&&token!=null) {
		Map<String, String> data = new HashMap<String, String>();
		data.put("token", token);
		data.put("user_id", user_id.toString());
		data.put("group_id", group_id_str);
		data.put("text", text);
		
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
	
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:25,代码来源:AddTextServlet.java


示例17: doGet

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doGet(HttpServletRequest req, HttpServletResponse resp) 
		throws ServletException, IOException {
	
	String user_id =req.getParameter("user_id");
	String token=AuthConfig.getToken();
	OutputStream os=resp.getOutputStream();
	
	if (user_id!=null&&token!=null) {
		Map<String, String> data=new HashMap<String,String>();
		data.put("user_id", user_id);
		data.put("token", token);
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:19,代码来源:GetAllTextGroupsServlet.java


示例18: doPost

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
	
	String group_id_str = req.getParameter("group_id");
	String text_id_str=req.getParameter("text_id");
	String text=req.getParameter("text");
	String token=AuthConfig.getToken();
	
	OutputStream os = resp.getOutputStream();
	
	if (group_id_str!=null&&text_id_str!=null&&text!=null&&token!=null) {
		Map<String, String> data=new HashMap<String ,String>();
		data.put("group_id", group_id_str);
		data.put("text_id", text_id_str);
		data.put("text", text);
		data.put("token", token);
		
		String returnAnswer = HttpRequest.post(authUrl).form(data).body();
		os.write(returnAnswer.getBytes("UTF-8"));
	}
	os.flush();
	os.close();
}
 
开发者ID:GroupControlDroid,项目名称:GroupControlDroidClient,代码行数:24,代码来源:UpdateTextServlet.java


示例19: fetchJson

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
public static JsonNode fetchJson(String accessToken, String user, String endpoint, String sort, String after) throws Exception {
//        https://oauth.reddit.com/user/asdf/comments.json?after=AFTER_ID&limit=100

        Map<String, String> params = new HashMap<>();
        params.put("limit", LIMIT.toString());
        params.put("sort", sort);

        if (after != null) {
            params.put("after", after);
        }

        HttpRequest req = HttpRequest.get("https://oauth.reddit.com/user/" + user + "/" + endpoint + ".json", params, true)
                .header("Authorization", "bearer " + accessToken)
                .header("User-Agent", "reddit-history/0.1 by " + user);

        printRateLimits(req);

        JsonNode node = convertJsonToNode(req.body());

        return node;
    }
 
开发者ID:dessalines,项目名称:reddit-history,代码行数:22,代码来源:App.java


示例20: run

import com.github.kevinsawicki.http.HttpRequest; //导入依赖的package包/类
@Override
protected void run(Date lastRun) {
    new SaneAsyncTask<Boolean>(1) {
        @Override
        public Boolean performTask() throws Throwable {
            JSONObject config = new JSONObject(HttpRequest.get(REMOTE_CONFIG_URL).body());
            app.getRemoteConfig().updateConfig(config);
            Log.d("Wikipedia", config.toString());
            return true;
        }

        @Override
        public void onCatch(Throwable caught) {
            // Don't do anything, but do write out a log statement. We don't particularly care.
            Log.d("Wikipedia", "Caught " + caught.toString());
        }
    }.execute();
}
 
开发者ID:gnosygnu,项目名称:xowa_android,代码行数:19,代码来源:RemoteConfigRefreshTask.java



注:本文中的com.github.kevinsawicki.http.HttpRequest类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java MBeanRegistration类代码示例发布时间:2022-05-21
下一篇:
Java Fieldable类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap