黄金价格数据应用程序接口提供方：https://www.nowapi.com/ 　　

　　

　　国际金价实时(盎司):https://www。诺瓦克皮。com/API/finance。GS金 　　

　　

　　国际金价实时(盎司) 　　

　　

　　作用：查询上海黄金交易所黄金价格、国际公制金价、国际贵金属期货价、工行纸黄金等。 　　

　　

　　测试示例http://api.k780.com/?号app=金融。gold _ price goldid=1201 app key=10003 sign=b 59 BC 3 ef 6191 EB 9 f 747 DD 4 e 83 c 99 F2 a4 format=JSON(示例中符号会不定期调整) 　　

　　

　　调用参数： 　　

　　

　　 　　

　　

　　返回格式： 　　

　　

　　{ ' result ' : { ' dt list ' : { ' 1201 ' : { ' sell _ price ' : ' 1716.73 '，' high_price': '1719.2 '，' goldid': '1201 '，' uptime ' : ' 2022-07-22 1333:58333:01 '，' varietynm '现货黄金，'品种： 'XAU '，'变动_保证金' : '-0.14% ','是_价格' : '1718.65 ','买入_价格' : '1716.3 ','变动_价格' : '-2.35 ','开仓_价格' : '1717.84 ','低价_价格' : '1712.77 ','尾盘_价格' :调用代码案例pom.xml 　　

　　

　　依赖项依赖项groupIdcn.hutool/groupId artifactIdhutool-all/artifactId版本5 .5 .9/版本/依赖项依赖项groupId组织。阿帕奇。http组件。客户端5/groupId artifactId http客户端5/artifactId版本5.1/版本/依赖项依赖项groupId组织。阿帕奇。http组件。客户端5/groupId artifactId http客户端5-fluent/artifactId版本5 .0 .3/版本/依赖项/依赖项调用方式1： 　　

　　

　　导入org。阿帕奇。公地。编解码器。字符集；导入org。阿帕奇。慧聪。客户端5。http。经典。方法。http帖子；导入org。阿帕奇。慧聪。客户端5。http。实体。urlencodedformentity导入org。阿帕奇。慧聪。客户端5。http。impl。经典。closea 　　

bleHttpClient;import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;import org.apache.hc.client5.http.impl.classic.HttpClients;import org.apache.hc.core5.http.HttpEntity;import org.apache.hc.core5.http.NameValuePair;import org.apache.hc.core5.http.io.entity.EntityUtils;import org.apache.hc.core5.http.message.BasicNameValuePair;import java.util.ArrayList;import java.util.List;public class HttpClientClassicApp { public static void main(String<> args) throws Exception { CloseableHttpClient httpClient = HttpClients.createDefault(); HttpPost httpPost = new HttpPost("http://api.k780.com/"); List<NameValuePair> nvps = new ArrayList<>(); nvps.add(new BasicNameValuePair("app", "finance.gold_price")); nvps.add(new BasicNameValuePair("goldid", "1201")); nvps.add(new BasicNameValuePair("appkey", "10003")); nvps.add(new BasicNameValuePair("sign", "b59bc3ef6191eb9f747dd4e83c99f2a4")); nvps.add(new BasicNameValuePair("format", "json")); httpPost.setEntity(new UrlEncodedFormEntity(nvps, Charsets.UTF_8)); CloseableHttpResponse response = httpClient.execute(httpPost); System.out.println(response.getCode() + " " + response.getReasonPhrase()); HttpEntity entity = response.getEntity(); String content = EntityUtils.toString(entity); System.out.println(content); EntityUtils.consume(entity); }}调用方式2：

　　

import cn.hutool.json.JSONObject;import cn.hutool.json.JSONUtil;import org.apache.hc.client5.http.async.methods.*;import org.apache.hc.client5.http.config.RequestConfig;import org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient;import org.apache.hc.client5.http.impl.async.HttpAsyncClients;import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManager;import org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManagerBuilder;import org.apache.hc.core5.concurrent.FutureCallback;import org.apache.hc.core5.http.Method;import org.apache.hc.core5.http.message.StatusLine;import org.apache.hc.core5.pool.PoolConcurrencyPolicy;import org.apache.hc.core5.reactor.IOReactorConfig;import org.apache.hc.core5.util.TimeValue;import org.apache.hc.core5.util.Timeout;import java.util.concurrent.Future;import java.util.concurrent.TimeUnit;public class HttpClient5App { public static void main(String<> args) { // 异步应用配置 IOReactorConfig ioReactorConfig = IOReactorConfig.custom() .setSoTimeout(Timeout.ofMilliseconds(250)) // 超时时间 .setSelectInterval(TimeValue.ofMilliseconds(50)) // 1.2 .build(); // setSoTimeout()====>连接上一个url，获取response的返回等待时间 // setSelectInterval()====>NIO中设置select的间隔 // 客户端连接配置 PoolingAsyncClientConnectionManager build = PoolingAsyncClientConnectionManagerBuilder.create() .setPoolConcurrencyPolicy(PoolConcurrencyPolicy.LAX) // 2.1 .setMaxConnPerRoute(6).build(); // 2.2 // poolConcurrencyPolicy() ====> STRICT模式通过加锁的方式对,LAX通过cas的方式宽松计数 // 设置STRICT，会使用StrictConnPool实现类；设置LAX ，会使用LaxConnPool实现类 // maxConnPerRoute ====> 每个route最多能有多少个connection // 创建客户端 CloseableHttpAsyncClient client = HttpAsyncClients.custom() .setIOReactorConfig(ioReactorConfig) .setConnectionManager(build) .disableAutomaticRetries() .build(); // automaticRetriesDisabled===>关闭自动重试 client.start(); String uri = "http://api.k780.com/"; SimpleHttpRequest httpRequest = SimpleHttpRequest.create(Method.GET.name(), uri); final SimpleHttpRequest request = SimpleRequestBuilder.copy(httpRequest) .addParameter("app", "finance.gold_price") .addParameter("goldid", "1201") .addParameter("appkey", "10003") .addParameter("sign", "b59bc3ef6191eb9f747dd4e83c99f2a4") .addParameter("format", "json") .build(); request.setHeader("Host", "api.k780.com"); RequestConfig config = RequestConfig.copy(RequestConfig.DEFAULT) .setConnectTimeout(150, TimeUnit.MILLISECONDS) .setConnectionRequestTimeout(200, TimeUnit.MILLISECONDS) .setResponseTimeout(100, TimeUnit.MILLISECONDS).build(); request.setConfig(config); long start = System.currentTimeMillis(); final Future<SimpleHttpResponse> future = client.execute( SimpleRequestProducer.create(request), SimpleResponseConsumer.create(), new FutureCallback<SimpleHttpResponse>() { @Override public void completed(final SimpleHttpResponse response) { System.out.println(request + "->" + new StatusLine(response)); System.out.println(response.getBody()); } @Override public void failed(final Exception ex) { System.out.println(request + "->" + ex); } @Override public void cancelled() { System.out.println(request + " cancelled"); } }); // 时间计算 try { SimpleHttpResponse simpleHttpResponse = future.get(); JSONObject jsonObject = JSONUtil.parseObj(simpleHttpResponse.getBodyText()); System.out.println("body=" + jsonObject); long end = System.currentTimeMillis(); System.out.println("时间差：" + (end - start)); } catch (Exception e) { long end = System.currentTimeMillis(); System.out.println("时间差：" + (end - start)); System.out.println(e); } // 线程等待 try { Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } }}