Kubernetes集群上的Apache Ignite和Spring第1部分:Spring Boot应用程序
在之前的一系列博客中,我们在Kubernetes集群上启动了一个Ignite集群。
在本教程中,我们将使用先前在Spring Boot Application上创建的Ignite集群。
让我们使用Spring Boot创建我们的项目。 Spring Boot应用程序将连接到Ignite集群。
让我们添加依赖项。
<?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。
第一步是添加反序列化的作业模型。
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; }
我们需要乔布斯的存储库。 当心该类需要可序列化。 Ignite将数据缓存在堆外。
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类存在的主要原因是为了方便进行编组。
如您所见,存储库具有@Cacheable批注。 这意味着我们的请求将被缓存。 就本示例而言,fetchFromIgnite方法是一种测试方法。 我们将使用它直接访问ignite缓存的数据。
我们还将添加控制器。
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); } }
控制器上的两种方法,一种是照常获取数据并将其缓存在后台,另一种是我们将用于测试的方法。
现在是时候配置使用Kubernetes集群上的节点的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; } }
我们创建了缓存。 它应使用Kubernetes TCP发现模式。
下一步是添加我们的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); } }
下一个博客将专注于将解决方案交付给kubernetes。
翻译自: https://www.javacodegeeks.com/2020/04/apache-ignite-and-spring-on-your-kubernetes-cluster-part-1-spring-boot-application.html
Kubernetes集群上的Apache Ignite和Spring第1部分:Spring Boot应用程序相关推荐
- Kubernetes集群上的Apache Ignite和Spring第3部分:测试应用程序
在上一个博客中,我们为Ignite应用程序创建了Kubernetes部署文件. 在此博客上,我们将在Kubernetes上部署Ignite应用程序. 我将在此使用minikube. 让我们先构建 mv ...
- Kubernetes集群上的Apache Ignite和Spring第2部分:Kubernetes部署
以前,我们已经成功创建了第一个由Apache Ignite支持的Spring boot Application. 在此博客上,我们将重点介绍Kubernetes方面需要做的事情,以便能够启动我们的应用 ...
- apache ignite_Kubernetes集群上的Apache Ignite和Spring第1部分:Spring Boot应用程序
apache ignite 在之前的一系列博客中,我们在Kubernetes集群上启动了一个Ignite集群. 在本教程中,我们将使用先前在Spring Boot Application上创建的Ign ...
- apache ignite_Kubernetes集群上的Apache Ignite和Spring第2部分:Kubernetes部署
apache ignite 以前,我们已经成功创建了第一个由Apache Ignite支持的Spring boot Application. 在此博客上,我们将重点介绍Kubernetes方面需要做的 ...
- apache ignite_Kubernetes集群上的Apache Ignite和Spring第3部分:测试应用程序
apache ignite 在上一个博客中,我们为Ignite应用程序创建了Kubernetes部署文件. 在此博客上,我们将在Kubernetes上部署Ignite应用程序. 我将在此使用minik ...
- 在Kubernetes集群上部署高可用Harbor镜像仓库
这里主要介绍使用kubectl部署Harbor镜像仓库到Kubernetes集群中. 使用Helm部署,参考: https://my.oschina.net/u/2306127/blog/181969 ...
- 在Kubernetes集群上部署和管理JFrog Artifactory
JFrog Artifactory是一个artifacts仓库管理平台,它支持所有的主流打包格式.构建工具和持续集成(CI)服务器.它将所有二进制内容保存在一个单一位置并提供一个接口,这使得用户在整个 ...
- 如何轻松地将可访问LAN的Pod部署到Kubernetes集群上
撰者 | Jack Wallen 译者 | Katie,责编 | Jerry 来源 | CSDN云计算 封图 | CSDN 下载自视觉中国 想要在Kubernetes集群上部署可访问LAN的Pod来达 ...
- k8s和harbor的集成_在Kubernetes集群上部署高可用Harbor镜像仓库
在Kubernetes集群上部署高可用Harbor镜像仓库 一.Kubernetes上的高可用Harbor方案 首先,我可以肯定给出一个回答:Harbor支持在Kubernetes部署.只不过Harb ...
最新文章
- C语言中,#include 和#include 的区别和注意点
- 关于 Repeater 控件嵌套的使用。在嵌套中添加 其它控件(如:按钮),并影响其它控件的方法,很重要哦,测试通过。...
- Testing BlogJet
- 解决SQL查询总是 超时已过期
- 2018下半年软考报名
- Linux下架设rsync服务器
- 存量电力系统_RCR新文:中国电力基础设施发展的物质存量和流量
- centos redis php扩展,手动在centos下安装redis及php扩展
- javascript设计模式——Module
- Acrobat专业版破解补丁AMTEmu+Win+v0.9.2
- 前端--阶段笔记(四)前后端交互
- C++ #include expects “FILENAME“ or <FILENAME>
- 产品破局思考:一个思维,一种策略
- OPA1612AIDR IC AUDIO 2 CIRCUIT 8SOIC
- IDEA全局搜索快捷键Ctrl+Shift+F无效,解决方法
- C语言初学者需要知道的十句话,听说不知道的人都没学好编程
- 实数傅立叶变换和复数傅立叶变换
- 书籍推荐:搜索引擎技术入门书籍
- 古龙群侠传 服务器维护,【图片】【原创】古龙群侠传最全流程攻略~~【环家的那只熊吧】_百度贴吧...
- c语言指针near,near指针和far指针