關(guān)于Ignite的介紹，這邊推薦三個(gè)鏈接進(jìn)行學(xué)習(xí)了解。

https://ignite.apache.org/，首選還是官網(wǎng)，不過(guò)是英文版，如果閱讀比較吃力可以選擇下方兩個(gè)鏈接。

https://www.oschina.net/p/apache-ignite?hmsr=aladdin1e1，開源中國(guó)上對(duì)Ignite的介紹，包含特性、架構(gòu)等內(nèi)容，比較詳細(xì)。

https://www.infoq.cn/article/apache-ignite-explorer，這個(gè)鏈接中將Ignite與Redis、Hazelcast等同類型產(chǎn)品做了比較。

 接下來(lái)我們開始實(shí)踐，首先需要在本地搭建一套Ignite服務(wù)，從官網(wǎng)上可以進(jìn)行下載，https://ignite.apache.org/docs/latest/installation/installing-using-zip：

這里需要注意的是，我們要下載的是安裝包，別下載了源碼。下載完畢后解壓，去到apache-ignite-2.8.1\bin目錄雙擊ignite.bat即可啟動(dòng)服務(wù)：

打印上圖中框出內(nèi)容即為啟動(dòng)成功，接下來(lái)我們創(chuàng)建一個(gè)Spring Boot項(xiàng)目用于整合Ignite的相關(guān)驗(yàn)證，目錄結(jié)構(gòu)如下：

父工程的pom：

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.22.RELEASE</version>
    <relativePath/>
</parent>

<properties>
    <h2.version>1.4.197</h2.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-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

Spring Boot的版本推薦為1.5.X這類較為穩(wěn)定的版本，從2.0.0開始的版本和Ignite會(huì)發(fā)生沖突，編譯時(shí)拋出如下錯(cuò)誤：

Error:(8, 8) java: 名稱沖突: org.apache.ignite.springdata.repository.IgniteRepository中的deleteAll(java.lang.Iterable<ID>)和org.springframework.data.repository.CrudRepository中的deleteAll(java.lang.Iterable<? extends T>)具有相同疑符, 但兩者均不覆蓋對(duì)方

這里還需要注意一點(diǎn)，如果不指定h2的版本為1.4.197，啟動(dòng)應(yīng)用時(shí)會(huì)拋出如下異常：

org.apache.ignite.internal.processors.query.IgniteSQLException: Failed to initialize system DB connection: jdbc:h2:mem:b9189e84-4966-4b03-8500-429a958cee4f;LOCK_MODE=3;MULTI_THREADED=1;DB_CLOSE_ON_EXIT=FALSE;DEFAULT_LOCK_TIMEOUT=10000;FUNCTIONS_IN_SCHEMA=true;OPTIMIZE_REUSE_RESULTS=0;QUERY_CACHE_SIZE=0;MAX_OPERATION_MEMORY=0;BATCH_JOINS=1;ROW_FACTORY="org.apache.ignite.internal.processors.query.h2.opt.H2PlainRowFactory";DEFAULT_TABLE_ENGINE=org.apache.ignite.internal.processors.query.h2.opt.GridH2DefaultTableEngine
 at org.apache.ignite.internal.processors.query.h2.ConnectionManager.connectionNoCache(ConnectionManager.java:213) ~[ignite-indexing-2.8.1.jar:2.8.1]
 at org.apache.ignite.internal.processors.query.h2.ConnectionManager.<init>(ConnectionManager.java:152) ~[ignite-indexing-2.8.1.jar:2.8.1]
 at org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing.start(IgniteH2Indexing.java:2114) ~[ignite-indexing-2.8.1.jar:2.8.1]
 at org.apache.ignite.internal.processors.query.GridQueryProcessor.start(GridQueryProcessor.java:256) ~[ignite-core-2.8.1.jar:2.8.1]
 at org.apache.ignite.internal.IgniteKernal.startProcessor(IgniteKernal.java:1978) ~[ignite-core-2.8.1.jar:2.8.1]
 at org.apache.ignite.internal.IgniteKernal.start(IgniteKernal.java:1212) ~[ignite-core-2.8.1.jar:2.8.1]

子模塊spring-boot-test-ignite中需要添加Ignite的依賴，版本需要與本地搭建的Ignite服務(wù)保持一致：

<dependency>
    <groupId>org.apache.ignite</groupId>
    <artifactId>ignite-spring-data</artifactId>
    <version>2.8.1</version>
</dependency>

接下來(lái)貼出Ignite的配置類IgniteConfig，通過(guò)動(dòng)態(tài)IP發(fā)現(xiàn)綁定到本地的Ignite服務(wù)，同時(shí)創(chuàng)建實(shí)例與緩存供本地訪問(wèn)：

@Configuration
class IgniteConfig {

    @Bean
    public Ignite igniteInstance() {

        TcpDiscoverySpi spi = new TcpDiscoverySpi();
        TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
        ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500"));
        spi.setIpFinder(ipFinder);

        IgniteConfiguration igniteConfig = new IgniteConfiguration();
        igniteConfig.setIgniteInstanceName("TestInstance");
        igniteConfig.setDiscoverySpi(spi);
        igniteConfig.setClientMode(true);

        CacheConfiguration cacheConfig = new CacheConfiguration("TestCache");
        cacheConfig.setIndexedTypes(Long.class, TestObject.class);
        igniteConfig.setCacheConfiguration(cacheConfig);
        return Ignition.start(igniteConfig);
    }
}

用于數(shù)據(jù)交互的測(cè)試類TestObject，注解@QuerySqlField的作用時(shí)告訴Ignite后續(xù)可以通過(guò)id字段發(fā)起查詢，如果沒(méi)有此注解也不影響數(shù)據(jù)的插入，但是查詢時(shí)會(huì)拋出Column not found的異常：

public class TestObject {

    @QuerySqlField(index = true)
    long id;
    String name;

    public TestObject(long id, String name) {

        this.id = id;
        this.name = name;
    }

    public long getId() {
        return id;
    }

    public void setId(long id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

通過(guò)實(shí)現(xiàn)IgniteRepository來(lái)創(chuàng)建查詢方式：

@RepositoryConfig(cacheName = "TestCache")
public interface TestRepository extends IgniteRepository<TestObject, Long> {

    TestObject findById(long id);
}

再下來(lái)是用于測(cè)試的接口及其對(duì)應(yīng)實(shí)現(xiàn)：

public interface TestService {

    TestObject save(TestObject testObject);

    TestObject findTestObjectById(long id);
}

@Service
public class TestServiceImpl implements TestService {

    @Autowired TestRepository testRepository;

    public TestObject save(TestObject testObject) {

        return testRepository.save(testObject.getId(), testObject);
    }

    public TestObject findTestObjectById(long id) {

        return testRepository.findById(id);
    }
}

倒數(shù)第二步是編寫用于測(cè)試的controller層：

@RestController
public class TestController {

    @Autowired
    TestService testService;

    @RequestMapping("/test")
    public TestObject savePerson(@RequestParam(value = "id") long id, @RequestParam(value = "name") String name) {

        return testService.save(new TestObject(id, name));
    }

    @RequestMapping("/find")
    public TestObject findByCode(@RequestParam(value = "id") long id) {

        return testService.findTestObjectById(id);
    }
}

啟動(dòng)類中需要注意添加注解@EnableIgniteRepositories，否則應(yīng)用是無(wú)法識(shí)別通過(guò)@RepositoryConfig修飾的Bean：

@SpringBootApplication
@EnableIgniteRepositories
public class IgniteApplication {

    public static void main(String[] args) {

        SpringApplication.run(IgniteApplication.class, args);
    }
}

啟動(dòng)應(yīng)用后通過(guò)postman進(jìn)行測(cè)試驗(yàn)證，首先創(chuàng)建一個(gè)TestObject的實(shí)例并塞入Ignite：

接下來(lái)通過(guò)id=12032進(jìn)行查詢：

成功返回！

整個(gè)實(shí)踐過(guò)程中踩了不少坑，也是希望這篇隨筆能為后面學(xué)習(xí)這塊內(nèi)容的同學(xué)節(jié)省一些時(shí)間吧。

參考資料：

https://ignite.apache.org/

https://www.oschina.net/p/apache-ignite?hmsr=aladdin1e1

https://www.infoq.cn/article/apache-ignite-explorer

https://blog.csdn.net/ltl112358/article/details/79399026

https://blog.csdn.net/qq_35051298/article/details/81452550

https://stackoverflow.com/questions/52652162/ignite-wont-start-with-spring-boot-2-0-5-h2-property-nested-joins-doesnt-exi

http://cn.voidcc.com/question/p-ofvlepsc-dr.html

到此這篇關(guān)于SpringBoot整合Apache Ignite的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)SpringBoot整合Apache Ignite內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論