消息中间件的编程主要涉及以下几个步骤：
选择消息中间件
根据项目需求选择合适的消息中间件，如ActiveMQ、JBossMQ、WebSphereMQ等。不同的消息中间件有不同的特性和调用方法，选择时需考虑项目需求、团队熟悉度以及成本等因素。
建立服务器
消息中间件通常需要搭建服务器，可以通过直接运行中间件提供的安装程序或通过包管理器进行安装。安装完成后，需要启动服务器以便客户端进行连接和通信。
编写客户端程序
使用消息中间件提供的API或客户端库来编写客户端程序。不同的消息中间件可能提供不同语言的客户端库，例如Java、Python、Go等。以下是一些常见语言的消息中间件客户端编程示例：
Java：
```java
import javax.jms.*；
import org.apache.activemq.ActiveMQConnectionFactory；
public class MessageProducer {
public static void main（String[] args） {
try {
// 创建连接工厂
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory（"tcp://localhost:61616"）；
// 创建连接
Connection connection = connectionFactory.createConnection（）；
// 创建会话
Session session = connection.createSession（false, Session.AUTO_ACKNOWLEDGE）；
// 创建目的地
Destination destination = session.createQueue（"TEST.QUEUE"）；
// 创建消息生产者
MessageProducer producer = session.createProducer（destination）；
// 创建消息
TextMessage message = session.createTextMessage（"Hello, World!"）；
// 发送消息
producer.send（message）；
// 关闭资源
producer.close（）；
session.close（）；
connection.close（）；
} catch （JMSException e） {
e.printStackTrace（）；
}
}
}
```
Python（使用RabbitMQ）：
```python
import pika
connection = pika.BlockingConnection（pika.ConnectionParameters（'localhost'））
channel = connection.channel（）
channel.queue_declare（queue='hello'）
channel.basic_publish（exchange='', routing_key='hello', body='Hello World!'）
print（" [x] Sent 'Hello World!'"）
connection.close（）
```
Go（使用RabbitMQ）：
```go
package main
import （
"fmt"
"github.com/streadway/amqp"
）
func failOnError（err error, msg string） {
if err != nil {
fmt.Printf（"%s: %s\n", msg, err）
return
}
}
func main（） {
conn, err := amqp.Dial（"amqp://guest:guest@localhost:5672/"）
failOnError（err, "Failed to connect to RabbitMQ"）
defer conn.Close（）
ch, err := conn.Channel（）
failOnError（err, "Failed to open a channel"）
defer ch.Close（）
q, err := ch.QueueDeclare（
"hello", // name
false, // durable
false, // delete when unused
false, // exclusive
false, // no-wait
nil, // arguments
）
failOnError（err, "Failed to declare a queue"）
body := "Hello World!"
err = ch.Publish（
"", // exchange
q.Name, // routing key
false, // mandatory
false, // immediate
amqp.Publishing{
ContentType: "text/plain",
Body:[]byte（body）,
}）
failOnError（err, "Failed to publish a message"）
fmt.Printf（" [x] Sent %s\n", body）
}
```
处理消息
编写消息消费者程序，通过消息中间件的API订阅并处理消息。以下是一个Java示例：