rabbitmq学习(java客户端)
2017-11-13 14:48
330 查看
1、rabbitmq采取的是集群安装
2、项目为maven工程,只需要在pom文件中加入:
3.源码
(一):Send.class
2、项目为maven工程,只需要在pom文件中加入:
<dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>3.6.1</version> </dependency> </dependencies>
3.源码
(一):Send.class
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; /** * Created by joyce on 2017/11/13. */ public class Send { private final static String QUEUE_NAME = "test"; public static void main(String[] args) throws Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("集群中的ip");
factory.setUsername("usrname"); factory.setPassword("passwd"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); channel.queueDeclare(QUEUE_NAME, false, false, false, null); String message = "Hello World! zyy"; channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8")); System.out.println(" [x] Sent '" + message + "'"); channel.close(); connection.close(); } }
(二):Recv.class
import com.rabbitmq.client.*; import java.io.IOException; /** * Created by joyce on 2017/11/13. */ public class Recv { private final static String QUEUE_NAME = "test"; public static void main(String[] args) throws Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("IP"); factory.setUsername("usrname"); factory.setPassword("passwd"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); channel.queueDeclare(QUEUE_NAME, false, false, false, null); Consumer consumer = new DefaultConsumer(channel){ @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, "UTF-8"); System.out.println(" [x] Received '" + message + "'"); } }; channel.basicConsume(QUEUE_NAME, true, consumer); } }
(三):直接跑main(),可以在控制台看见输出...
看到我请叫我去写作业_(wechat:jshasmith0826)
相关文章推荐
- RabbitMQ学习之Java客户端连接测试(二)
- RabbitMQ学习之Java客户端连接测试(二)
- RabbitMQ学习之Java客户端带权限连接测试
- 黑马程序员 【】java学习之路——TCP(三)客户端上传文件到服务器
- RPC学习--C#使用Thrift简介,C#客户端和Java服务端相互交互
- Memcached学习笔记 — 第四部分:Memcached Java 客户端-gwhalin(2)-性能测试
- JAVA学习第六十三课 — 关于客户端服务端 && URL类 & URLConnection
- JXCELL实例学习与研究(七) 之 JAVA的GUI对JXCELL的小客户端,显示各种表格状态的方法
- RabbitMQ学习之主题topic(java)
- Java_socket程序学习01-一个客户端对一个服务器
- RabbitMQ学习之Headers交换类型(java)
- Java_socket程序学习03-一个客户端对一个服务器-交互(客户端)--02
- Java_socket程序学习04-一个服务器对多个一个客户端
- kafka 学习笔记(二)之Java Producer客户端
- RabbitMQ学习之工作队列(java)
- 【Java学习笔记】TCP客户端/服务器端
- RabbitMQ学习及实践2---介绍及简单Java实现
- 【Java学习笔记】UDP客户端/服务器端
- RabbitMQ学习之远程过程调用(RPC)(java)
- 跟学韩老师学习java-servlet篇之四一个案例,接受客户端提交请求与复选框的数组