分布式队列的使用案例

使用OrientDB实现一个持久化,分布式和事务的队列很简单。不需要一个特定的队列API,最简单的方式就是用OrientDB SQL,可以在很多驱动中工作。

创建队列类:

create class queue

也可以每个队列一个类。Push操作的例子如下:

insert into queue set text = "this is the first message", date = date()

由于OrientDB默认保持插入记录的顺序,简单的删除操作就可以实现Pop:

delete from queue return before limit 1

"return before"可以返回删除的记录内容。Peek操作直接使用:

select from queue limit 1

就这些了,你拥有一个持久化,分布式和事务的队列。