pom.xmljava
<dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.1.2</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.37</version> </dependency> </dependencies>
Resource/mqConn.jsonjson
{
"HostIP":"127.0.0.1",
"Port":5672,
"userName":"guest",
"passWord":"guest"
}
src/jsonbean.javaapp
import com.alibaba.fastjson.annotation.JSONField; public class jsonbean { @JSONField(name = "HostIP") private String HostIP; @JSONField(name ="Port") private int Port; @JSONField(name = "userName") private String userName; @JSONField(name = "passWord") private String passWord; public String getHostIP() { return HostIP; } public void setHostIP(String hostIP) { this.HostIP = hostIP; } public int getPort() { return Port; } public void setPort(int port) { this.Port = port; } public String getUserName() { return userName; } public void setUserName(String userName) { this.userName = userName; } public String getPassWord() { return passWord; } public void setPassWord(String passWord) { this.passWord = passWord; } }
src/nbconnectMQ.javathis
import com.alibaba.fastjson.JSONReader; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import java.io.FileReader; import java.io.IOException; import java.util.concurrent.TimeoutException; public class nbConnectMQ { public Connection nbCreateConnection() throws IOException { String filePath="resources/mqConn.json"; JSONReader jsonReader=new JSONReader(new FileReader(filePath)); jsonbean jsonstr=jsonReader.readObject(jsonbean.class); ConnectionFactory connectionFactory=new ConnectionFactory(); connectionFactory.setHost(jsonstr.getHostIP()); connectionFactory.setPort(jsonstr.getPort()); connectionFactory.setUsername(jsonstr.getUserName()); connectionFactory.setPassword(jsonstr.getPassWord()); Connection connection= null; try { connection = connectionFactory.newConnection(); } catch (TimeoutException e) { e.printStackTrace(); } return connection; } }
src/appRunspa
import java.io.IOException; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; public class appRun { private final static String QUEUE_NAME="Hello"; public static void main(String[] args) throws IOException { Connection connectMQ=new nbConnectMQ().nbCreateConnection(); Channel nbchannel=connectMQ.createChannel(); String Message="Hello world"; nbchannel.basicPublish("", QUEUE_NAME, null, Message.getBytes()); System.out.println("Sended Message"); connectMQ.close(); } }