在Java中使用消息机制通常需要依赖于消息中间件，比如常用的ActiveMQ、RabbitMQ、Kafka等。下面我以使用ActiveMQ为例，简单介绍如何在Java中编写消息生产者和消费者的代码。

首先，你需要下载并安装ActiveMQ消息中间件，并启动ActiveMQ服务器。然后在你的Java项目中引入相关的ActiveMQ依赖库。

接下来，我们分别编写消息生产者和消息消费者的代码：

消息生产者代码：

import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class JmsProducer {public static void main(String[] args) throws JMSException {// 创建连接工厂ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");// 创建连接Connection connection = connectionFactory.createConnection();connection.start();// 创建会话Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);// 创建队列Destination destination = session.createQueue("example.queue");// 创建消息生产者MessageProducer producer = session.createProducer(destination);// 创建文本消息TextMessage message = session.createTextMessage("Hello, ActiveMQ!");// 发送消息producer.send(message);System.out.println("Message sent: " + message.getText());// 关闭资源producer.close();session.close();connection.close();}
}

消息消费者代码：

import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class JmsConsumer {public static void main(String[] args) throws JMSException {// 创建连接工厂ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");// 创建连接Connection connection = connectionFactory.createConnection();connection.start();// 创建会话Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);// 创建队列Destination destination = session.createQueue("example.queue");// 创建消息消费者MessageConsumer consumer = session.createConsumer(destination);// 接收消息Message message = consumer.receive();if (message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;System.out.println("Received message: " + textMessage.getText());}// 关闭资源consumer.close();session.close();connection.close();}
}

以上是一个简单的使用ActiveMQ实现消息生产者和消费者的示例代码。在实际使用过程中，你需要根据你的具体需求来配置连接信息、处理异常等。同时，如果使用其他消息中间件，代码中的相关类和方法名称也会有所不同。