在之前的一系列博客中，我們在Kubernetes集群上啟動(dòng)了一個(gè)Ignite集群。
在本教程中，我們將使用先前在Spring Boot Application上創(chuàng)建的Ignite集群。

讓我們使用Spring Boot創(chuàng)建我們的項(xiàng)目。 Spring Boot應(yīng)用程序?qū)⑦B接到Ignite集群。

讓我們添加依賴項(xiàng)。

<?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.gkatzioura</groupId><artifactId>job-api-ignite</artifactId><version>0.0.1-SNAPSHOT</version><name>job-api-ignite</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.apache.ignite</groupId><artifactId>ignite-kubernetes</artifactId><version>2.7.6</version></dependency><dependency><groupId>org.apache.ignite</groupId><artifactId>ignite-spring</artifactId><version>2.7.6</version><exclusions><exclusion><groupId>org.apache.ignite</groupId><artifactId>ignite-indexing</artifactId></exclusion></exclusions></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.12</version><scope>provided</scope></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>

與之前的教程一樣，我們將使用GitHub的Job api。

第一步是添加反序列化的作業(yè)模型。

package com.gkatzioura.jobapi.model; import java.io.Serializable; import lombok.Data; @Data public class Job implements Serializable { private String id; private String type; private String url; private String createdAt; private String company; private String companyUrl; private String location; private String title; private String description; }

我們需要喬布斯的存儲庫。 當(dāng)心該類需要可序列化。 Ignite將數(shù)據(jù)緩存在堆外。

package com.gkatzioura.jobapi.repository; import java.util.ArrayList; import java.util.List; import com.gkatzioura.jobapi.model.Job; import lombok.Data; import org.apache.ignite.Ignite; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Repository; import org.springframework.web.client.RestTemplate; @Repository public class GitHubJobRepository { private static final String JOB_API_CONSTANST = " https://jobs.github.com/positions.json?page= {page}" ; public static final String GITHUBJOB_CACHE = "githubjob" ; private final RestTemplate restTemplate; private final Ignite ignite; GitHubJobRepository(Ignite ignite) { this .restTemplate = new RestTemplate(); this .ignite = ignite; } @Cacheable (value = GITHUBJOB_CACHE) public List<Job> getJob( int page) { return restTemplate.getForObject(JOB_API_CONSTANST,JobList. class ,page); } public List<Job> fetchFromIgnite( int page) { for (String cache: ignite.cacheNames()) { if (cache.equals(GITHUBJOB_CACHE)) { return (List<Job>) ignite.getOrCreateCache(cache).get( 1 ); } } return new ArrayList<>(); } @Data private static class JobList extends ArrayList<Job> { } }

JobList類存在的主要原因是為了方便進(jìn)行編組。
如您所見，存儲庫具有@Cacheable批注。 這意味著我們的請求將被緩存。 就本示例而言，fetchFromIgnite方法是一種測試方法。 我們將使用它直接訪問ignite緩存的數(shù)據(jù)。

我們還將添加控制器。

package com.gkatzioura.jobapi.controller; import java.util.List; import com.gkatzioura.jobapi.model.Job; import com.gkatzioura.jobapi.repository.GitHubJobRepository; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping ( "/jobs" ) public class JobsController { private final GitHubJobRepository gitHubJobRepository; JobsController(GitHubJobRepository gitHubJobRepository) { this .gitHubJobRepository = gitHubJobRepository; } @GetMapping ( "/github/{page}" ) public List<Job> gitHub( @PathVariable ( "page" ) int page) { return this .gitHubJobRepository.getJob(page); } @GetMapping ( "/github/ignite/{page}" ) public List<Job> gitHubIgnite( @PathVariable ( "page" ) int page) { return this .gitHubJobRepository.fetchFromIgnite(page); } }

控制器上的兩種方法，一種是照常獲取數(shù)據(jù)并將其緩存在后臺，另一種是我們將用于測試的方法。

現(xiàn)在是時(shí)候配置使用Kubernetes集群上的節(jié)點(diǎn)的Ignite客戶端了。

package com.gkatzioura.jobapi.config; import lombok.extern.slf4j.Slf4j; import org.apache.ignite.Ignite; import org.apache.ignite.Ignition; import org.apache.ignite.cache.spring.SpringCacheManager; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; import org.apache.ignite.spi.discovery.tcp.ipfinder.kubernetes.TcpDiscoveryKubernetesIpFinder; import org.springframework.cache.annotation.EnableCaching; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration @EnableCaching @Slf4j public class SpringCacheConfiguration { @Bean public Ignite igniteInstance() { log.info( "Creating ignite instance" ); TcpDiscoveryKubernetesIpFinder tcpDiscoveryKubernetesIpFinder = new TcpDiscoveryKubernetesIpFinder(); tcpDiscoveryKubernetesIpFinder.setNamespace( "default" ); tcpDiscoveryKubernetesIpFinder.setServiceName( "job-cache" ); TcpDiscoverySpi tcpDiscoverySpi = new TcpDiscoverySpi(); tcpDiscoverySpi.setIpFinder(tcpDiscoveryKubernetesIpFinder); IgniteConfiguration igniteConfiguration = new IgniteConfiguration(); igniteConfiguration.setDiscoverySpi(tcpDiscoverySpi); igniteConfiguration.setClientMode( false ); return Ignition.start(igniteConfiguration); } @Bean public SpringCacheManager cacheManager(Ignite ignite) { SpringCacheManager springCacheManager = new SpringCacheManager(); springCacheManager.setIgniteInstanceName(ignite.name()); return springCacheManager; } }

我們創(chuàng)建了緩存。 它應(yīng)使用Kubernetes TCP發(fā)現(xiàn)模式。

下一步是添加我們的Main類。

package com.gkatzioura.jobapi; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cache.annotation.EnableCaching; @SpringBootApplication @EnableCaching public class IgniteKubeClusterApplication { public static void main(String[] args) { SpringApplication.run(IgniteKubeClusterApplication. class , args); } }

下一個(gè)博客將專注于將解決方案交付給kubernetes。

翻譯自: https://www.javacodegeeks.com/2020/04/apache-ignite-and-spring-on-your-kubernetes-cluster-part-1-spring-boot-application.html

總結(jié)

以上是生活随笔為你收集整理的Kubernetes集群上的Apache Ignite和Spring第1部分：Spring Boot应用程序的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。