在Java程序中，可以使用內(nèi)置的java.util.concurrent.BlockingQueue作為消息隊列存放的容器，來實現(xiàn)一個簡單的消息隊列。

具體實現(xiàn)如下，在這個例子中，我們創(chuàng)建了一個生產(chǎn)者線程和一個消費者線程，他們共享同一個阻塞隊列。

public class MyBlockingQueue {private static final BlockingQueue<String> queue=new LinkedBlockingQueue<>();public static void main(String[] args) {Thread producer= new Thread(()->{for(int i=0 ; true; i++){try{String str="生產(chǎn)者發(fā)送消息";System.out.println(str);queue.put(str);Thread.sleep(1000);}catch(Exception e){Thread.currentThread().interrupt();}}});producer.start();Thread consumer=new Thread(()->{while(true){try{String take = queue.take();System.out.println("消費者獲取到消息-->"+take);}catch (Exception e){Thread.currentThread().interrupt();}}});consumer.start();}}

上述程序運行結(jié)果如下：

?在實際應用中，你可能會用到更復雜的消息隊列服務，如RabbitMQ、Kafka等，但上述代碼展示了如何利用Java標準庫中的并發(fā)工具來實現(xiàn)基本的消息隊列功能。