一、JDK自带的java.net.HttpURLConnection包
/*** 查询外汇牌价* 不需要查数据库，写到service层就可以了*/public String getExchangeQuotation(String ccy) throws IOException {HttpURLConnection connection = null;BufferedReader reader = null;StringBuilder response = new StringBuilder();try {// 创建URL对象URL url = new URL("http://10.51.162.15:9088/SDS/0001/TTT001100"); //准生产环境// 打开连接connection = (HttpURLConnection) url.openConnection();// 设置请求方法为POSTconnection.setRequestMethod("POST");// 启用输出流connection.setDoOutput(true);//规定为json格式，不然会报错“报文体不是json格式”connection.setRequestProperty("Content-Type","application/json;utf-8");connection.setRequestProperty("Accept","application/json");// 设置请求报文头headerconnection.setRequestProperty("VersionId", "0001");connection.setRequestProperty("OrigSender", "NIU001"); //渠道号connection.setRequestProperty("CtrlBits", "00000000");connection.setRequestProperty("AreaCode", "010");connection.setRequestProperty("SpanId", "NIU001464f070a8b00b5984d02389ce063946a");connection.setRequestProperty("TraceId", "NIU0019c1523b96ea6463c849c21407bd7fd87");//四个信息需要动态生成//1）时间戳,毫秒级不重复String tranTimestamp = System.currentTimeMillis() + "";//2）交易序号，,毫秒级不重复String consumerSeqNo = "DMT001" + tranTimestamp;//3）日期LocalDate today = LocalDate.now();DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd");String tranDate = today.format(formatter);// 设置请求体String requestBody = "{\"head\":{" +"\"versionId\":\"0001\"," +"\"ctrlBits\":\"10000000\"," +"\"tranDate\":\"" + tranDate +"\"," +"\"consumerSeqNo\":\""+consumerSeqNo +"\","+"\"tranTimestamp\":\""+tranTimestamp +"\"," +"\"branchId\":\"90157\"," +"\"agentBranchId\":\"90157\"," +"\"areaCode\":\"0000\"}," +"\"body\":{" +"\"dateTran\":\"" + tranDate +"\"," +"\"seqNo\":\"\"," +"\"typeTran\":" + "\"1\"," +"\"ccy\":\""+ ccy +"\"" +"}}";//System.out.println(requestBody);//将请求报文以字节流的形式写入connection里，此时还没有进行http的访问OutputStream os = connection.getOutputStream();os.write(requestBody.getBytes());os.flush();//System.out.println(requestBody.toString());// 获取响应码int responseCode = connection.getResponseCode();System.out.println("Response Code: " + responseCode);String responseMessage = connection.getResponseMessage();System.out.println("Response Message: " +responseMessage);//获取响应报文的headInputStream inputStream = connection.getInputStream();reader = new BufferedReader(new InputStreamReader(inputStream));String line;while((line = reader.readLine())!=null){response.append(line);}//打印//log.info(response.toString());} catch (Exception e) {log.info("外汇牌号查询失败");e.printStackTrace();}finally {reader.close();connection.disconnect();return response.toString();}}
二、用apache的httpcore
/***<dependency>* <groupId>org.apache.httpcomponents</groupId>* <artifactId>httpcore</artifactId>* <version>4.4.12</version>* </dependency>* <dependency>* <groupId>org.apache.httpcomponents</groupId>* <artifactId>httpclient</artifactId>* <version>4.5.10</version>* </dependency>**/
public String getExchangeQuotation02() throws IOException {CloseableHttpClient httpClient = HttpClients.createDefault();//创建post请求HttpPost post = new HttpPost("http://10.51.162.15:9088/SDS/0001/TTT001100");//设置请求头post.setHeader("VersionId", "0001");post.setHeader("OrigSender", "NIU001");post.setHeader("CtrlBits", "00000000");post.setHeader("AreaCode", "010");post.setHeader("SpanId", "NIU001464f070a8b00b5984d02389ce063946a");post.setHeader("TraceId", "NIU0019c1523b96ea6463c849c21407bd7fd87");//设置为json格式post.setHeader("Content-Type","application/json;utf-8");post.setHeader("Accept","application/json");//设置请求体String jsonBody = "{\"head\":{\"ctrlBits\":\"10000000\",\"branchId\":\"90157\",\"versionId\":\"0001\",\"areaCode\":\"0000\",\"agentBranchId\":\"90157\",\"tranTimestamp\":\"1723799154910\",\"tranDate\":\"20241010\",\"tranCode\":\"SAV001100\",\"userId\":\"BOBDM1\"}," +"\"body\":{\"dateTran\":\"20241010\",\"seqNo\":\"\",\"typeTran\":\"1\",\"ccy\":\"\"}}";HttpEntity entity = new StringEntity(jsonBody, StandardCharsets.UTF_8);post.setEntity(entity);//发送请求并获取CloseableHttpResponse response = httpClient.execute(post);String result = "";try{//解析responseHttpEntity responseEntity = response.getEntity();result = EntityUtils.toString(responseEntity);EntityUtils.consume(entity);System.out.println(result);}finally {response.close();return result;}}
三、okhttp3
/*** <dependency>* <groupId>com.squareup.okhttp3</groupId>* <artifactId>okhttp</artifactId>* <version>4.9.3</version>* <classifier>javadoc</classifier>* </dependency>**/
public String getExchangeQuotation03() throws IOException {OkHttpClient client = new OkHttpClient();// 构造请求体RequestBodyMediaType JSON = MediaType.parse("application/json; charset=utf-8");String json = "{\"head\":{\"ctrlBits\":\"10000000\",\"branchId\":\"90157\",\"versionId\":\"0001\",\"areaCode\":\"0000\",\"agentBranchId\":\"90157\",\"tranTimestamp\":\"1723799154910\",\"tranDate\":\"20241010\"}," +"\"body\":{\"dateTran\":\"20241010\",\"seqNo\":\"\",\"typeTran\":\"1\",\"ccy\":\"\"}}";RequestBody requestBody = RequestBody.create(JSON, json);Request request = new Request.Builder().url("http://10.51.162.15:9088/SDS/0001/TTT001100").addHeader("VersionId", "0001") //在这里添加请求报文的headers.addHeader("CtrlBits", "00000000").addHeader("AreaCode", "010").addHeader("OrigSender","NIU001").addHeader("SpanId", "NIU001464f070a8b00b5984d02389ce063946a").addHeader("TraceId", "NIU0019c1523b96ea6463c849c2 1407bd7fd87").post(requestBody) //在这里指定post方法.build();Response response = client.newCall(request).execute();return response.body().string();}
四、用springframework的
public String getExchangeQuotation04(){//1.创建restTemplate实例RestTemplate restTemplate = new RestTemplate();//2.构造请求头HttpHeaders headers = new HttpHeaders();headers.add("Content-Type","application/json;utf-8");headers.add("Accept","application/json");headers.add("VersionId", "0001");headers.add("OrigSender", "NIU001");headers.add("CtrlBits", "00000000");headers.add("AreaCode", "010");headers.add("SpanId", "NIU001464f070a8b00b5984d02389ce063946a");headers.add("TraceId", "NIU0019c1523b96ea6463c849c21407bd7fd87");//3.构造请求体这里不会写了。//4.发送请求ResponseEntity<String> response = restTemplate.exchange("http://10.51.162.15:9088/SDS/0001/TTT001100",HttpMethod.POST,(org.springframework.http.HttpEntity<?>) entity,String.class);return response.toString();}
