原文:RabbitMQ(二):理解消息通信RabbitMQ一、消费者、生产者和信道 生产者(producer):生产者创建消息,然后发布(发送)到代理服务器(RabbitMQ),可以说发送消息的程序就是生产者。什么是消息?消息包含两部分:有效载荷和标签。有效载荷就是传输的数据,可以是任何内容,包括j... ...
分类:
其他好文 时间:
2019-04-12 00:48:07
阅读次数:
125
Java并发编程知识总结——开篇词 这篇博客是开始总结Java并发的开篇,主要说下下面总结Java并发编程相关知识的思路、呈现出自己理解的Java并发知识的全景图,为后面Java并发知识总结的复习提供线索和记忆脉络。主要学习和借鉴的主要资料有:《极客时间》并发编程专栏、《Java并发实战》等。 Ja ...
分类:
编程语言 时间:
2019-04-12 00:41:31
阅读次数:
166
RabbitMQ即一个消息队列,主要是用来实现应用程序的异步和解耦,同时也能起到消息缓冲,消息分发的作用。消息中间件在互联网公司的使用中越来越多,刚才还看到新闻阿里将RocketMQ捐献给了Apache,当然了今天的主角还是讲RabbitMQ。消息中间件最主要的作用是解耦,中间件最标准的用法是生产者生产消息传送到队列,消费者从队列中拿取消息并处理,生产者不用关心是谁来消费,消费者不用关心谁在生产消
分类:
编程语言 时间:
2019-04-11 19:50:09
阅读次数:
192
1、kafka是什么 类JMS消息队列,结合JMS中的两种模式,可以有多个消费者主动拉取数据,在JMS中只有点对点模式才有消费者主动拉取数据。 kafka是一个生产-消费模型。 Producer:生产者,只负责数据生产,生产者的代码可以集成到任务系统中。 数据的分发策略由producer决定,默认是 ...
分类:
其他好文 时间:
2019-04-09 09:27:11
阅读次数:
137
线程间通信——等待唤醒机制,避免争夺同一资源; 锁对象可以是任意Object类的子类对象; 包子案例: 包子案例——生产者和消费者: 代码实现: 关键就是在于两个线程使用同一个锁对象! 这边是主程序调用这两个线程时候传入的同一个对象! 包子铺线程类——生产者: 其中,baozi类作为成员变量,并且重 ...
分类:
编程语言 时间:
2019-04-07 20:28:55
阅读次数:
152
永远在循环(loop)里调用 wait 和 notify,不是在 If 语句现在你知道wait应该永远在被synchronized的背景下和那个被多线程共享的对象上调用,下一个一定要记住的问题就是,你应该永远在while循环,而不是if语句中调用wait。因为线程是在某些条件下等待的——在我们的例子 ...
分类:
其他好文 时间:
2019-04-07 12:43:06
阅读次数:
710
加入事务的方法: txSelect() txCommit() txRollback() 生产者: 消费者: ...
分类:
其他好文 时间:
2019-04-06 09:58:44
阅读次数:
113
rabbit引入交换机概念。 交换机与生产者绑定。 队列与消费者绑定。 队列又与交换机绑定。 扇形交换机是 fanout类型的。 类似于其他消息中间件的 topic。一对多(生产者推送消息到指定交换机,一个或多个绑定了此交换机的消费者的队列都可以收到此交换机的消息) 生产者: 消费者: ...
分类:
其他好文 时间:
2019-04-06 09:47:06
阅读次数:
120
直连交换机类型为:direct。加入了路由键routingKey的概念。 就是说 生产者投递消息给指定交换机的指定路由键。 只有绑定了此交换机指定路由键的消息队列才可以收到消息。 生产者: 消费者: ...
分类:
其他好文 时间:
2019-04-06 09:34:04
阅读次数:
92