在Java程序中,可以使用内置的java.util.concurrent.BlockingQueue作为消息队列存放的容器,来实现一个简单的消息队列。
具体实现如下,在这个例子中,我们创建了一个生产者线程和一个消费者线程,他们共享同一个阻塞队列。
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="生产者发送消息";
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();
}
}
上述程序运行结果如下:
在实际应用中,你可能会用到更复杂的消息队列服务,如RabbitMQ、Kafka等,但上述代码展示了如何利用Java标准库中的并发工具来实现基本的消息队列功能。