工具类utils:
package co.yixiang.utils;
import com.alibaba.fastjson.JSONObject;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
/**
* @author xyp
* @data 2020/7/3
*/
public class HttpUtil {
/**
* 向指定URL发送GET方法的请求
*
* @param url
* 发送请求的URL
* @param param
* 请求参数
* @param authorization
* 请求参数(允许为空)
* @param cookie
* 请求参数(允许为空)
* @return URL 所代表远程资源的响应结果
*/
public static String sendGet(String url, Map<String, String> param, String authorization, String cookie) {
String result = "";
BufferedReader in = null;
try {
StringBuffer query = new StringBuffer();
for (Map.Entry<String, String> kv : param.entrySet()) {
query.append(URLEncoder.encode(kv.getKey(), "UTF-8") + "=");
query.append(URLEncoder.encode(kv.getValue(), "UTF-8") + "&");
}
if (query.lastIndexOf("&") > 0) {
query.deleteCharAt(query.length() - 1);
}
String urlNameString = url + "?" + query.toString();
URL realUrl = new URL(urlNameString);
// 打开和URL之间的连接
URLConnection connection = realUrl.openConnection();
// 设置通用的请求属性
connection.setRequestProperty("accept", "*/*");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
if (authorization != null){
connection.setRequestProperty("Authorization", authorization);
}
if (cookie != null){
connection.setRequestProperty("Cookie", cookie);
}
// 建立实际的连接
connection.connect();
// 定义 BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
e.printStackTrace();
}
// 使用finally块来关闭输入流
finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return result;
}
/**
* 向指定 URL 发送POST方法的请求
*
* @param url
* 发送请求的 URL
* @param param
* 请求参数
* @param authorization
* 请求参数(允许为空)
* @param cookie
* 请求参数(允许为空)
* @return 所代表远程资源的响应结果
*/
public static String sendPost(String url, Map<String, String> param, String authorization, String cookie) {
PrintWriter out = null;
BufferedReader in = null;
String result = "";
try {
String para = "";
for (String key : param.keySet()) {
para += (key + "=" + param.get(key) + "&");
}
if (para.lastIndexOf("&") > 0) {
para = new String(para.substring(0, para.length() - 1));
}
String urlNameString = url + "?" + para;
URL realUrl = new URL(urlNameString);
// 打开和URL之间的连接
HttpURLConnection conn = (HttpURLConnection)realUrl.openConnection();
// 设置通用的请求属性
conn.setRequestProperty("accept", "*/*");
conn.setRequestProperty("connection", "Keep-Alive");
conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
if (authorization != null){
conn.setRequestProperty("Authorization", authorization);
}
if (cookie != null){
conn.setRequestProperty("Cookie", cookie);
}
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 发送请求参数
out.print(param);
// flush输出流的缓冲
out.flush();
// 定义BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
e.printStackTrace();
}
// 使用finally块来关闭输出流、输入流
finally {
try {
if (out != null) {
out.close();
}
if (in != null) {
in.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
return result;
}
/**
* 发送post请求
* @param url
* 发送请求的 URL
* @param param
* 请求参数
* @param authorization
* 请求参数(允许为空)
* @param cookie
* 请求参数(允许为空)
* @return 所代表远程资源的响应结果
*/
public static String sendPost(String url, String param, String authorization, String cookie) {
PrintWriter out = null;
BufferedReader in = null;
String result = "";
try {
URL realUrl = new URL(url + "?" + param);
// 打开和URL之间的连接
URLConnection conn = realUrl.openConnection();
// 设置通用的请求属性
conn.setRequestProperty("accept", "*/*");
conn.setRequestProperty("connection", "Keep-Alive");
conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
if (authorization != null){
conn.setRequestProperty("Authorization", authorization);
}
if (cookie != null){
conn.setRequestProperty("Cookie", cookie);
}
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 发送请求参数
out.print(param);
// flush输出流的缓冲
out.flush();
// 定义BufferedReader输入流来读取URL的响应
in = new BufferedReader(
new InputStreamReader(conn.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
e.printStackTrace();
}
//使用finally块来关闭输出流、输入流
finally {
try {
if (out != null) {
out.close();
}
if (in != null) {
in.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
return result;
}
public static void main(String[] args) {
//请求参数
String body = "{\"status\":[1],\"customerid\":[\"20000047\"],\"sdorderno\":[1580459238218],\"total_fee\":[\"100.00\"],\"paytime\":[1580459238218],\"sign\":[\"a0397aef701f13e79133566582afa903\"]}";
//请求头,可变,根据实际来
String authorization = "Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiJ0ZXN0IiwiYXV0aCI6ImliRXF1aXBtZW50TGlzdDplZGl0LGliQmFua0NhcmRMaXN0Omxpc3QsaWJCYW5rRmxvdzpsaXN0LGliRGlzYnVyc2VtZW50UmVjb3JkOmxpc3QsaWJCYW5rQ2FyZExpc3Q6YWRkLGliQmFua0NhcmRMaXN0OmVkaXQsaWJEaXNidXJzZW1lbnQ6YWRkLGliUGF5bWVudE9yZGVyOmRlbCxpYkJhbmtBbGFybTpkZWwsaWJFcXVpcG1lbnRBbGFybTplZGl0LHRlc3QsaWJCYW5rQWxhcm06ZWRpdCxpYkRpc2J1cnNlbWVudDpsaXN0LGliRXF1aXBtZW50QWxhcm06ZGVsLGliUGF5bWVudE9yZGVyOmxpc3QsaWJQYXltZW50T3JkZXI6YWRkLGliRXF1aXBtZW50TGlzdDpkZWwsaWJCYW5rQWxhcm06bGlzdCxpYkJhbmtDYXJkTGlzdDpkZWwsaWJFcXVpcG1lbnRMaXN0OmFkZCxpYk1lcmNoYW50SW5mb3JtYXRpb246bGlzdCxpYkVxdWlwbWVudEFsYXJtOmxpc3QsaWJFcXVpcG1lbnRMaXN0Omxpc3QsaWJEaXNidXJzZW1lbnQ6ZGVsLGliRGlzYnVyc2VtZW50OmVkaXQsaWJQYXltZW50T3JkZXI6ZWRpdCIsImV4cCI6MTU5Mzc4MzUwMn0.p_AEZfwErkRQCJ9ctZBNgf9fniLPGogV9rxSGyZEqStOOv7YEdAcefsAJNnUxzOOhLCdwhGBBAEDDVn3x43A3A";
//cookie值,可变,根据实际来
String cookie = "YSHOP-TOEKN=Bearer%20eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiJ0ZXN0IiwiYXV0aCI6ImliRXF1aXBtZW50TGlzdDplZGl0LGliQmFua0NhcmRMaXN0Omxpc3QsaWJCYW5rRmxvdzpsaXN0LGliRGlzYnVyc2VtZW50UmVjb3JkOmxpc3QsaWJCYW5rQ2FyZExpc3Q6YWRkLGliQmFua0NhcmRMaXN0OmVkaXQsaWJEaXNidXJzZW1lbnQ6YWRkLGliUGF5bWVudE9yZGVyOmRlbCxpYkJhbmtBbGFybTpkZWwsaWJFcXVpcG1lbnRBbGFybTplZGl0LHRlc3QsaWJCYW5rQWxhcm06ZWRpdCxpYkRpc2J1cnNlbWVudDpsaXN0LGliRXF1aXBtZW50QWxhcm06ZGVsLGliUGF5bWVudE9yZGVyOmxpc3QsaWJQYXltZW50T3JkZXI6YWRkLGliRXF1aXBtZW50TGlzdDpkZWwsaWJCYW5rQWxhcm06bGlzdCxpYkJhbmtDYXJkTGlzdDpkZWwsaWJFcXVpcG1lbnRMaXN0OmFkZCxpYk1lcmNoYW50SW5mb3JtYXRpb246bGlzdCxpYkVxdWlwbWVudEFsYXJtOmxpc3QsaWJFcXVpcG1lbnRMaXN0Omxpc3QsaWJEaXNidXJzZW1lbnQ6ZGVsLGliRGlzYnVyc2VtZW50OmVkaXQsaWJQYXltZW50T3JkZXI6ZWRpdCIsImV4cCI6MTU5Mzc4MzUwMn0.p_AEZfwErkRQCJ9ctZBNgf9fniLPGogV9rxSGyZEqStOOv7YEdAcefsAJNnUxzOOhLCdwhGBBAEDDVn3x43A3A";
String jsionResult=HttpUtil.sendPost("http://192.168.18.1:8013/api/callback",body,authorization,cookie);
System.out.println(jsionResult);
}
}
后台接受请求的Controller类里请求对应的方法:
/**
* 测试方法
* /
@PostMapping(value = "/callback")
@Log("订单回调到下游")
@ApiOperation("订单回调到下游")
public ResponseEntity<Object> callback(@RequestBody Map<String,Object> callbackPama){
return new ResponseEntity<>(ibBankOrderApiService.callback(callbackPama), HttpStatus.OK);
}
这种方式类似于用Java的方式模拟postman软件里的post请求:
文章浏览阅读212次。存储过程定义作用使用范围怎么操作创建无参无输出存储过程创建有参无输出存储过程创建无参有输出存储过程创建有参有输出存储过程判断存储过程是否存在删除存储过程定义存储过程是一个预编译的sql语句 ,编译后可多次使用。优势:响应时间上来说有优势,可以给我们带来运行效率提高的好处,且使用存储过程的系统更加稳定缺点:维护性较差,相对于简单sql,存储过程并没有什么优势,并且在进行调试时比较困难作用可以提高运行效率,并且使用存储过程的系统更稳定。更多的可以参考 【随风飘扬中】的 存储过程的作用和意义使用范_sqlserver exec无数据
文章浏览阅读105次。QFile类QFile类提供了一个可以读写文件的接口,用法如下://读取.txt文件中每一行信息并处理,读一般的二进制文件的话不需要QIODevice::TextQFile file("in.txt");if (!file.open(QIODevice::ReadOnly | QIODevice::Text))return;while (!file.atEnd()) ..._qt4 gui qdebug
文章浏览阅读311次。最近在看Thinking in java 第4版,发现有些地方翻译的特别晦涩,难懂。这个时候呢, 我首先做到就是找出第3版的中文版,还有英文版,一对比,哈哈,就明白什么意思了,实在还不明白的,g.cn一下,hoho,也基本上能明白了。很多朋友也遇到了和我一样的问题,而且也有牛人的具体回复。有了网络,感觉现在学习什么知识,都那么大方便。_有网络之后方便的事
文章浏览阅读1.1w次,点赞4次,收藏9次。OpenMesh学习和使用过程中的系列笔记3,半边数据结构介绍_半边结构遍历一点的所有半边
文章浏览阅读2k次。/** * @param $codeLength 指定要生成的长度 * @param $codeCount 指定需要的个数 * @return array 生成字符串的集合 */function randomCode($codeLength, $codeCount){ $str1 = '1234567890'; $str2 = 'ABCDEFGHIJKL...
文章浏览阅读323次。精髓是这一段@jit(nopython=True)def solve_Heff(nk, V): L, nk = V.shape def Mterm2(q): M2 = np.zeros((nk, nk), dtype=np.complex128) Ap = np.power(np.absolute(V),2).sum(axis=1).copy() # 预处理一个常数项 for i in range(nk): _np.zeros() @jit(nopython=true)
文章浏览阅读212次。from locust import HttpLocust, TaskSet, taskimport jsonfrom common import readConfigclass UserBehavior(TaskSet): # 定义用户行为def on_start(self): # 当模拟用户开始执行TaskSet类的时候,on_start方法会被调用passdef get_headers(..._locust代码怎么提取上一个接口返回的token
文章浏览阅读192次。方法一:echarts-for-react 是一个非常简单的针对于 React 的 Echarts 封装插件。和使用所有其他插件一样,首先,我们需要 install 它:第一步:npminstall --save echarts(依赖)npminstall --save echarts-for-react第二步:在我们的项目中导入:importReactEcharts fro..._react echarts
文章浏览阅读4.1k次,点赞15次,收藏46次。前言:____ 最近一直在研究建图,对google的开源SLAM框架 Cartographer 进行了源码梳理,发现很多巧妙的算法设计,结合原论文 《Real-time Loop Closure in 2D LIDAR SLAM》 的理论简介,才恍然理解其核心目的就是实现实时回环;为了达到实时的效果,其引入了一些其他方法来进行计算加速,理解其中的思想方法,整个过程有点漫长但很有意思。Cartographer 中工程设计中可参考的点很多,本篇先把其概率地图更新部分的流程进行说明,用图示意的方式对其思路进.._cartographer 地图
文章浏览阅读76次。前言关于防火墙的相关概念,我们在之前的文章中已经进行了相关的介绍,这里就不再重复。感兴趣的朋友可以移步初识Linux防火墙今天重点记录一下,如何使用iptables来搭建网络防火墙,实现控制访问。实验环境准备如果要实现网络防火墙,至少需要三台主机A,B,C,B用来搭建网络防火墙,A来模拟局域网内主机,..._iptables验证来自本机的连接是否可以通过防火墙
文章浏览阅读9k次。scp 命令==================scp 可以在 2个 linux 主机间复制文件;命令基本格式: scp [可选参数] file_source file_target======从 本地 复制到 远程======* 复制文件: * 命令格式: scp local_fileremote_username@remote_ip:remote_folder 或者..._scp命令格式
文章浏览阅读1.2w次,点赞3次,收藏29次。作者简介牧之 百度云高级研发工程师负责百度云Noah智能异常检测算法相关工作,在自动异常检测、智能故障诊断等方向有广泛的实践经验。干货概览流量,是系统的黄金指标之一..._百度流量回放测试