ignite + spring boot + 本地服务器 1.安装ignite服务器 2.spring boot 项目搭建 github链接:https://github.com/lick468/ignite_demo

下载链接: https://ignite.apache.org/download.cgi#binaries

解压之后本地启动,进入安装目录之后,使用命令: ignite.bat ..examplesconfigexample-ignite.xml

 启动成功示例如下:

ignite + spring boot + 本地服务器
1.安装ignite服务器
2.spring boot 项目搭建    github链接:https://github.com/lick468/ignite_demo
本地启动多台,构建集群
ignite + spring boot + 本地服务器
1.安装ignite服务器
2.spring boot 项目搭建    github链接:https://github.com/lick468/ignite_demo

2.spring boot 项目搭建 github链接:https://github.com/lick468/ignite_demo

pom.xml 依赖 ignite的pom版本需要和下载的版本一致,本文使用的都是2.11.0版本

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--ignite 配置 -->

        <dependency>
            <groupId>org.apache.ignite</groupId>
            <artifactId>ignite-core</artifactId>
            <version>2.11.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.ignite</groupId>
            <artifactId>ignite-spring</artifactId>
            <version>2.11.0</version>
        </dependency>
        
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

特别的,设置一下h2的版本,否则启动失败

<properties>
    <h2.version>1.4.197</h2.version>
</properties>

配置文件 igniteConfig.java

    @Bean
    public Ignite igniteInstance() {
        // Preparing IgniteConfiguration using Java APIs
        IgniteConfiguration cfg = new IgniteConfiguration();

        // The node will be started as a client node.
        cfg.setClientMode(true);

        // Classes of custom Java logic will be transferred over the wire from this app.
        cfg.setPeerClassLoadingEnabled(true);

        // Setting up an IP Finder to ensure the client can locate the servers.
        TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
        ipFinder.setAddresses(Collections.singletonList("127.0.0.1:47500..47509"));
        cfg.setDiscoverySpi(new TcpDiscoverySpi().setIpFinder(ipFinder));

        // Starting the node
        return Ignition.start(cfg);
    }

测试controller : IgniteController

package com.nenu.controller;

import lombok.extern.slf4j.Slf4j;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * @author :lichuankang
 * @date :2021/10/25 14:45
 * @description :ignite控制器
 */
@RestController
@Slf4j
public class IgniteController {

    @Resource
    private Ignite ignite;

    @GetMapping(value = "/igniteWrite")
    public String testIgniteWrite() {
        IgniteCache<String, String> cache = ignite.getOrCreateCache("myCache");
        cache.put("name", "this is name");
        cache.put("age", "24");
        return "success";
    }

    @GetMapping(value = "/igniteRead")
    public String igniteRead() {
        IgniteCache<String, String> cache = ignite.cache("myCache");
        return cache.get("name");
    }

    @GetMapping(value = "/write")
    public String igniteWriteByInput(String key, String value) {
        IgniteCache<String, String> cache = ignite.getOrCreateCache("myCache");
        cache.put(key, value);
        return "success";
    }

    @GetMapping(value = "/read")
    public String igniteWriteByRead(String key) {
        IgniteCache<String, String> cache = ignite.cache("myCache");
        return cache.get(key);
    }

}

执行结果 先赋值,后获取值

ignite + spring boot + 本地服务器
1.安装ignite服务器
2.spring boot 项目搭建    github链接:https://github.com/lick468/ignite_demo

ignite + spring boot + 本地服务器
1.安装ignite服务器
2.spring boot 项目搭建    github链接:https://github.com/lick468/ignite_demo

ignite + spring boot + 本地服务器
1.安装ignite服务器
2.spring boot 项目搭建    github链接:https://github.com/lick468/ignite_demo
ignite + spring boot + 本地服务器
1.安装ignite服务器
2.spring boot 项目搭建    github链接:https://github.com/lick468/ignite_demo