队列 - 请问Java里的LinkedBlockingQueue如何在分布式下使用

PHPzhong2017-04-18 10:28:23

分布式你还是用中间件吧。concurrent里的东西不知道怎么应用到分布式环境下，应该是不简单，不然也不会有这么多MQ吧。

天蓬老师2017-04-18 10:28:23

hazelcast

import com.hazelcast.config.Config;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
 
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
 
public class DistributedQueue {
    public static void main(String[] args) throws InterruptedException {
        Config config = new Config();
        HazelcastInstance h = Hazelcast.newHazelcastInstance(config);
        BlockingQueue<String> queue = h.getQueue("my-distributed-queue");
        queue.offer("item");
        String item = queue.poll();
 
        //Timed blocking Operations
        queue.offer("anotheritem", 500, TimeUnit.MILLISECONDS);
        String anotherItem = queue.poll(5, TimeUnit.SECONDS);
 
        //Indefinitely blocking Operations
        queue.put("yetanotheritem");
        String yetanother = queue.take();
    }
}

ringa_lee2017-04-18 10:28:23

你这分布式环境，还想只有一个队列，你这内存得有多大啊。
如果非要只有一个队列的话，可以将LinkedBlockingQueue包一层，对外提供一个HTTP服务，然后让分布式中其他的机器，调用这个服务就行了。

PHP中文网2017-04-18 10:28:23

LinkedBlockingQueue不建议 很容易出问题啊 容量就是个问题 太大了问题 太小了问题又是一大堆