溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹“如何使用Ignite+SpringCloud+Docker創建REST應用”，在日常操作中，相信很多人在如何使用Ignite+SpringCloud+Docker創建REST應用問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”如何使用Ignite+SpringCloud+Docker創建REST應用”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！
本文將講解基于Spring Cloud和Ignite的RESTful Web服務的創建過程。該服務是將Ignite用作為高性能內存數據庫的容器化應用，使用HashiCorp Consul進行服務發現，并通過Spring Data存儲庫抽象與Ignite集群進行交互，容器化通過Docker實現。
為了方便起見，可以使用Consul的官方Docker鏡像（需要先安裝Docker）：
啟動Consul的Docker鏡像：
docker run -d -p 8500:8500 -p 8600:8600/udp --name=consul consul agent -server -ui -node=server-1 -bootstrap-expect=1 -client=0.0.0.0
創建該應用可以從https://start.spring.io入手。
這里需要Spring Web和Spring Consul Discovery模塊，Spring Web是創建REST應用的最簡單的框架之一，Spring Consul Discovery可以將多個Spring應用實例組合成一個服務。
@Configuration
@EnableIgniteRepositories(value = "com.github.sammyvimes.bootnite.repo")
public class IgniteConfig {
}在編譯應用之前，需要解決一些問題。Ignite不支持Spring Data的H2版本。因此必須在構建配置中重置H2的版本（無論是Gradle還是Maven）：
ext {
set('h3.version', '1.4.197')
}另外，Spring Cloud Consul和hystrix還有已知的問題，因此需要將其排除：
implementation ('org.springframework.cloud:spring-cloud-starter-consul-discovery') {
exclude group: 'org.springframework.cloud', module: 'spring-cloud-netflix-hystrix'
}最后，關于Spring Data BeanFactory，還有一個問題：BeanFactory會查找一個名為igniteInstance的bean，而自動配置則提供一個名為ignite的bean，后續會解決這個問題。
但是現在，需要對配置類做如下的修改來解決BeanFactory的問題：
@Configuration
@EnableIgniteRepositories(value = "com.github.sammyvimes.bootnite.repo")
public class IgniteConfig {
@Bean(name = "igniteInstance")
public Ignite igniteInstance(Ignite ignite) {
ignite.active(true);
return ignite;
}
}下面會創建一個基于Ignite Spring Data存儲庫的CRUD服務。
下面會從最常見的示例開始，即Employee類：
public class Employee implements Serializable {
private UUID id;
private String name;
private boolean isEmployed;
// constructor, getters & setters
}定義數據模型之后，就要添加配置器bean：
@Bean
public IgniteConfigurer configurer() {
return igniteConfiguration -> {
CacheConfiguration cache = new CacheConfiguration("employeeCache");
cache.setIndexedTypes(UUID.class, Employee.class);
igniteConfiguration.setCacheConfiguration(cache);
};
}這樣當應用啟動后，會部署employeeCache緩存，該緩存包含可加快對Employee實體查詢的索引。
接下來，與其他Spring Data存儲服務一樣，需要創建一個存儲庫和一個服務：
@Repository
@RepositoryConfig(cacheName = "employeeCache")
public interface EmployeeRepository
extends IgniteRepository<Employee, UUID> {
Employee getEmployeeById(UUID id);
}注意RepositoryConfig注解，其將存儲庫鏈接到即將使用的緩存，之前已經使用employeeCache字符串作為名字創建了一個緩存。
接下來是一個使用該存儲庫的簡單服務：
@Service
@Transactional
public class EmployeeService {
private final EmployeeRepository repository;
// constructor injection FTW
public EmpoyeeService(final EmployeeRepository repository) {
this.repository = repository;
}
public List<Employee> findAll() {
return StreamSupport.stream(repository.findAll().spliterator(), false)
.collect(Collectors.toList());
}
public Employee create(final String name) {
final Employee employee = new Employee();
final UUID id = UUID.randomUUID();
employee.setId(id);
employee.setEmployed(true);
employee.setName(name);
return repository.save(id, employee);
}
}這里有2個方法，create和findAll，用于演示Ignite和Spring Data的集成。
下面會配置一些端點，以便可以訪問和修改數據，一個簡單的控制器就可以了：
@RestController
@RequestMapping("/employee")
public class EmployeeController {
private final EmpoyeeService service;
public EmployeeController(final EmployeeService service) {
this.service = service;
}
@GetMapping
public ResponseEntity<List<Employee>> employees() {
return ResponseEntity.ok(service.findAll());
}
@PostMapping
public ResponseEntity<Employee> create(@RequestParam final String name) {
return ResponseEntity.ok(service.create(name));
}
}這樣，這個應用就開發完了。
現在就可以啟動應用，通過向/employee發送POST請求來創建數據，并通過發送GET請求來查詢數據。
雖然這個應用性能很高，但是分布式存儲的優勢在哪里呢？
可以通過Docker來創建和管理應用節點。
首先在工程的根目錄，為應用創建一個Dockerfile：
FROM adoptopenjdk:8-jre-hotspot RUN mkdir /opt/app && mkdir /opt/ignite COPY build/libs/bootnite-0.0.1-SNAPSHOT.jar /opt/app/app.jar CMD ["java", "-jar", "/opt/app/app.jar"]
簡單地說：獲取OpenJDK，為應用創建目錄，往鏡像中復制應用的二進制文件，并創建默認命令以啟動應用。
現在，在工程的根目錄中，運行gradle build和docker build -t ignite-test-app：0.1 -f .dockerfile。
接下來，通過Docker，同時啟動應用的兩個實例。
通過編寫了以下shell腳本，可以幫助啟動節點：
MacOS：
export HOST_IP=$(ipconfig getifaddr en0)
docker run -P -e HOST_IP=${HOST_IP} -e DISCO_PORT=$2 -p $2:47500 --name $1 ignitionLinux：
export HOST_IP=$(ip -4 addr show docker0 | grep -Po 'inet \K[\d.]+')
docker run -P -e HOST_IP=${HOST_IP} -e DISCO_PORT=$2 -p $2:47500 --name $1 ignition在這里所做的是獲取主機IP地址，以便可以使用端口轉發，并使節點之間可以相互通信。使用-p參數為Docker容器創建端口轉發規則，并使用-e參數將外部端口的值保存在容器的環境中，以便稍后可以在如下配置中使用這些值：
spring:
application:
name: myapp
instance_id: 1
cloud:
consul:
enabled: true
host: ${HOST_IP}
service-registry:
enabled: true
ignition:
disco:
host: ${HOST_IP}
port: ${DISCO_PORT}這里添加了自定義配置參數ignition.disco.host和ignition.disco.port，這些參數將在自定義IP探測器中使用。注意還通過添加主機IP地址來更改Consul的配置。
現在，更改Ignite Java配置后就完成了：
@Bean
public TcpDiscoveryConsulIpFinder finder(final ConsulDiscoveryClient client,
final ConsulServiceRegistry registry,
final ConsulDiscoveryProperties properties,
@Value("${ignition.disco.host}") final String host,
@Value("${ignition.disco.port}") final int port) {
return new TcpDiscoveryConsulIpFinder(client, registry, properties, host, port);
}
@Bean
public IgniteConfigurer configurer(final TcpDiscoveryConsulIpFinder finder) {
return igniteConfiguration -> {
CacheConfiguration cache = new CacheConfiguration("employeeCache");
cache.setIndexedTypes(UUID.class, Employee.class);
igniteConfiguration.setCacheConfiguration(cache);
final TcpDiscoverySpi tcpDiscoverySpi = new TcpDiscoverySpi();
tcpDiscoverySpi.setIpFinder(finder);
igniteConfiguration.setDiscoverySpi(tcpDiscoverySpi);
};
}執行下面的測試，可以看下是否一切正常：
啟動一個應用實例：./starter/start.sh test1 30000；
將一些數據提交到實例；例如curl -d'name = admin'http：// localhost：32784/employee，不同的容器使用不同的端口；
通過在終端中執行docker ps確定容器的端口轉發規則（規則類似于0.0.0.0:32784->8080/tcp），確定要使用的端口；
啟動另一個節點：./starter/start.sh test2 30001；
停止第一個節點（如果是從終端啟動容器，則可以使用Ctrl + c）；
執行對第二個節點的GET請求，并驗證從此請求獲取的數據和從第一個請求獲取的數據是否相同：curl http://localhost:32785/employee。
注意，此curl命令中的端口和上一個curl命令中的端口不相同，因為兩個應用實例占用不同的端口。
到此，關于“如何使用Ignite+SpringCloud+Docker創建REST應用”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
