【hazelcast入门系列之六】hazelcast的Reliable Topic使用

发表于 | Edited on | 分类于
Symbols count in article： 831 | Reading time ≈ 1 mins.

本文介绍hazelcast中Reliable Topic的使用。

Reliable Topic的基础使用

首先放上示例代码
示例代码
代码整体结构与Topic类似，但是通过配置可以发现Reliable Topic是依赖于Ringbuffer存储的。
这样可以获取以下优势：

  1. 由于Ringbuffer默认有一个异步备份，所以事件不会丢失。
  2. 由于每个ITopic有自己的Ringbuffer，所以在生产者快，消费者慢的情况下也没问题。
  3. 由于普通的ITopic背后的事件系统是基于其他数据结构的，例如集合的监听器，可能会遇到隔离问题。在Reliable Topic上就完全没有这个问题了。
    阅读全文 »

【hazelcast入门系列之四】hazelcast的Ringbuffer使用

发表于 | Edited on | 分类于
Symbols count in article： 2.1k | Reading time ≈ 2 mins.

本文介绍hazelcast中Ringbuffer的使用。

Ringbuffer的基础使用

首先放上基础代码
示例代码

代码主要包含三部分：

  1. main方法 对Ringbuffer进行配置，开启两个线程分别进行Ringbuffer的消费和生产。
  2. 消费者方法 sampleRingbufferConsumer 消耗Ringbuffer中的内容。
  3. 生产者方法 包括两种 sampleRingbufferProducer 和sampleRingbufferProducerWithFail 主要区别是OverflowPolicy不一样。

通过运行main方法即可以看到Ringbuffer的生产和消费，虽然有报错异常，但是用来说明Ringbuffer的生产、消费机制已经足够了。

这里注意一下Ringbuffer与Queue的区别，Queue被消耗后就不存在了，但是Ringbuffer可以让不同消费者以不同的offset进行消费，只要这个指针大于等于headSequence，小于等于tailSequence即可。

阅读全文 »

github私有仓库迁移指南

发表于 | Edited on | 分类于
Symbols count in article： 243 | Reading time ≈ 1 mins.


今天Github开放了个人账户无限私有仓库！以前在coding.net有几个私有仓库，赶紧顺便迁移过来。

阅读全文 »

【hazelcast入门系列之三】hazelcast的Queue、MultiMap、Set、List

发表于 | Edited on | 分类于
Symbols count in article： 1.8k | Reading time ≈ 2 mins.

本文介绍hazelcast中Queue、MultiMap、Set、List的使用。

Queue的使用

首先是一个简单的例子，生产者-消费者模式。
Producer代码
Consumer代码
启动一个生产者会以1秒1个的速度放入队列数据，最后放入-1。
消费者会每5秒消费一个队列数据，如果取得的数据为-1，则停止。停止前再次放入一个-1。
这样可以启动多个消费者共同消费同一个队列，当消费完毕后同时停止。并且由于都是在同一个机器执行，hazelcast自身会组成一个集群，所以queue消息共享。

阅读全文 »

【hazelcast入门系列之二】hazelcast的map

发表于 | Edited on | 分类于
Symbols count in article： 7.4k | Reading time ≈ 7 mins.

本文介绍hazelcast中map的相关操作，包括作为一个分布式的map有哪些功能、hazelcast的一些特色map功能。

一、安装hazelcast

从官网下载最新版本的软件包。本次以Hazelcast IMDG 3.11.1进行示例。

  1. 下载后将zip包或者tar包拷贝到centos合适的目录

  2. 进入bin目录修改start.sh ,添加如下代码。可以开启对map的rest访问。

    1
    JAVA_OPTS="$JAVA_OPTS -Dhazelcast.rest.enabled=true"

  3. 到bin目录启动hazelcast， ./start.sh

阅读全文 »