Aop面向切面编程
Aop不是替代oop,oop的补充（架构模式）
通用的流程代码，从业务代码中抽离出来，定义（封装）成独立的，可插拔的组件，根据需要以装配的形式动态插入需要的业务方法
Spring Aop提供了基础的Aop支持，基于JDK,动态代理和CGLib库实现的，方法代理AspectJ 提供强大的复杂的AOP支持。基于字节码生成，在编译，类加载，运行时都可以，不止方法还可以是字段
RESTTemplate 请求第三方 RESTful API（以火币为例）
API文档：
工程目录：
工程所需的依赖：
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.2.5.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.newer</groupId>
<artifactId>kline</artifactId>
<version>0.1</version>
<name>kline</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>11</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
Tick.java
package com.newer.kline;
import java.util.Arrays;
public class Tick {
// 字段名称 数据类型 描述
// id long 调整为新加坡时间的时间戳，单位秒，并以此作为此K线柱的id
// amount float 以基础币种计量的交易量
// count integer 交易次数
// open float 本阶段开盘价
// close float 本阶段收盘价
// low float 本阶段最低价
// high float 本阶段最高价
// vol float 以报价币种计量的交易量
long id;
double amount;
int count;
double open;
double close;
double low;
double high;
double vol;
// double [] kib;
// double [] ask;
public Tick() {
}
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public double getAmount() {
return amount;
}
public void setAmount(double amount) {
this.amount = amount;
}
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
public double getOpen() {
return open;
}
public void setOpen(double open) {
this.open = open;
}
public double getClose() {
return close;
}
public void setClose(double close) {
this.close = close;
}
public double getLow() {
return low;
}
public void setLow(double low) {
this.low = low;
}
public double getHigh() {
return high;
}
public void setHigh(double high) {
this.high = high;
}
public double getVol() {
return vol;
}
public void setVol(double vol) {
this.vol = vol;
}
@Override
public String toString() {
return "Tick [id=" + id + ", amount=" + amount + ", count=" + count + ", open=" + open + ", close=" + close
+ ", low=" + low + ", high=" + high + ", vol=" + vol + "]";
}
}
HomeController.java
package com.newer.kline;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
public class HomeController {
// 注入业务逻辑或数据操作
// 从第三方API接口获得数据
@GetMapping("/kline")
public String kline() {
// 服务端从第三方（火币）获得数据
// RestTemplate是java的Http客户端：ttpURLConnection, Apache HttpComponents, and others.
// Vue中 axios:JS Http客户端
RestTemplate restTemplate=new RestTemplate();
String url = "https://api.huobi.me/market/detail/merged?symbol=btcusdt";
// 第一种方式：发送GET请求，从响应中获得相应的数据
// return restTemplate.getForEntity(url, String.class).getBody();
// 第二种方式：发送HTTP任意请求
HttpHeaders headers=new HttpHeaders();
// headers.put(HttpHeaders.AUTHORIZATION);
// 设置HTTP请求头
headers.set(HttpHeaders.CONTENT_TYPE, "application/json");
headers.set(HttpHeaders.AUTHORIZATION, "令牌");
HttpEntity requestEntity=new HttpEntity<>(null,headers);
// 发送HTTP任意请求，POST,PUT,DELETE
return restTemplate.exchange(
url,
HttpMethod.GET,
requestEntity,
String.class)
.getBody();
}
}
这样，我们就可以从第三方API接口获取数据
@Scheduled的使用
如果我们想从第三方API接口不断获得实时更新的数据，可以采用@Scheduled 中的频率和时间间隔。
KlineJob.java
package com.newer.kline;
import java.util.Date;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
@Component
public class KlineJob {
// 假设执行耗费时间为5秒
// 时间 频率 延时（时间间隔）
// 0 0 0
// 1 10 15
// 2 20 30
// 3 30 45
// 4 40 60
// 固定的频率
@Scheduled(fixedRate = 1000*10)
public void job() {
// System.out.println("固定的频率"+new Date().toLocaleString());
//// 5
// try {
// Thread.sleep(5000);
// } catch (InterruptedException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// HttpClient,UrlConnection发送Http请求
// RestTemplate(WebClient) 访问其他的RESTful API
// RestController 自己定义RESTful API
RestTemplate restTemplate=new RestTemplate();
String url="https://api.huobi.me/market/detail/merged?symbol=ethusdt";
HttpMethod method=HttpMethod.GET;
HttpEntity requestEntity=null;
String json= restTemplate.exchange(
url,
method,
requestEntity,
String.class).getBody();
// 写入MongoDB
// 写入文档数据库
System.out.println(json);
}
// 固定的延时
@Scheduled(fixedDelay = 1000*10)
public void job2() {
System.out.println("固定延时"+new Date().toLocaleString());
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
KlineApplication.java(@EnableScheduling)
package com.newer.kline;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@EnableScheduling
@SpringBootApplication
public class KlineApplication {
public static void main(String[] args) {
SpringApplication.run(KlineApplication.class, args);
}
}
控制台输出：
可以看到程序从第三方API接口在不断的获取实时的数据。
以上就是RESTTemplate 请求第三方 RESTful API，@Scheduled的使用以及Spring Aop面向切面编程部分知识，有问题的小伙伴，欢迎留言！！！
