stomp java 客户端
时间: 2023-10-25 09:08:42 浏览: 190
您可以使用Java编写STOMP(简单文本定向消息传递协议)的客户端。下面是一个简单的示例代码:
```java
import org.apache.activemq.transport.stomp.Stomp;
import org.apache.activemq.transport.stomp.StompConnection;
public class StompClient {
public static void main(String[] args) {
try {
StompConnection connection = new StompConnection();
connection.open("localhost", 61613);
connection.connect("username", "password");
connection.subscribe("/queue/test", Stomp.Headers.Subscribe.AckModeValues.AUTO);
while (true) {
StompFrame frame = connection.receive();
System.out.println("Received message: " + frame.getBody());
connection.ack(frame);
}
connection.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
上面的示例是使用ActiveMQ作为消息中间件的情况,您可以根据自己的实际情况进行相应的修改。确保在运行代码之前,您已经安装并配置了STOMP服务器。
阅读全文