一、生产者发送消息的过程 首先介绍一下 Kafka 生产者发送消息的过程： + Kafka 会将发送消息包装为 ProducerRecord 对象， ProducerRecord 对象包含了目标主题和要发送的内容，同时还可以指定键和分区。在发送 ProducerRecord 对象前，生产者会先把键和 ...
分类：
其他好文 时间：
2019-08-19 09:50:48
阅读次数：
73
fabric 共识机制 由于fabric是分布式的系统，因此需要共识机制来保障各个节点以相同的顺序状态保存账本，达成一致性。 在当前fabric1.4版本中，存在三种共识机制，分别是solo，kafka，etcdraft。交易的共识包括3个阶段的处理：提议阶段、打包阶段和验证阶段。 1.Solo 共 ...
分类：
其他好文 时间：
2019-08-17 10:41:16
阅读次数：
336
借助标志位publicclasslight{publicstaticvoidmain(String[]args){Tvtv=newTv();newPlayer(tv).start();newWatcher(tv).start();}}//生产者演员classPlayerextendsThread{Tvtv;publicPlayer(Tvtv){this.tv=tv;}publicvoidrun()
分类：
编程语言 时间：
2019-08-16 11:51:04
阅读次数：
87
生产者消费者模式管程法通过容器中介，将数据放入和取出wait()导致当前线程等待，直到另一个线程调用该对象的notify()或notyfyAll()方法notify()唤醒正在等待对象监视器的单个线程,notifyAll()唤醒正在等待对象监视器的所有线程publicclasstuble{publicstaticvoidmain(String[]args){SynContainercontaine
分类：
编程语言 时间：
2019-08-15 22:55:23
阅读次数：
132
第17课-信号量同步编程 17.1 核心概念--进程同步 一组并发进程进行互相合作、互相等待，使得各进程按一定的顺序执行的过程称为进程间的同步。 17.2 生产者消费者问题 1. 问题描述 这里面有两个角色：生产者和消费者。假设生产者生产的产品需要两步才能完成并且使用。但是，当生产者刚刚完成了对产品 ...
分类：
其他好文 时间：
2019-08-14 14:38:01
阅读次数：
76
定义一个model类 定义一个接口 定义一个抽象基类 通过2张表来做消息处理，实现补发等操作 业务实现类 本例子中 ProcessCompletedEvent 是定义的一个 流程完成事件，流程完成事件后触发后续业务，通过流程也业务分离 业务调用处 ...
分类：
其他好文 时间：
2019-08-14 13:02:44
阅读次数：
96
生产者需要将要发送的数据转换成字节数组才能通过网络发送给kafka,对于一些简单的数据，kafka自带了一些序列化工具， 如：StringSerializer Double Long Integer Byte，它们都实现了 Serializer 接口，但是如果你要发送的数据是一个对象 Persion ...
分类：
其他好文 时间：
2019-08-13 15:12:15
阅读次数：
72
一、简单示例： 1）创建一个spring boot项目： 2）配置application.yml 3）创建列队配置： 4）消费者： 5）生产者： 6）测试： 二、路由模式： 1）路由/列队配置： @Configuration public class RabbitMQConfiguration { ...
分类：
编程语言 时间：
2019-08-13 00:18:37
阅读次数：
110
消息过滤消息过滤是指消费者不希望消费topic里的所有消息，而是只消费部分特定的消息。从topic中挑选出这些特定的消息，就是所谓的消息过滤。通过消息过滤可以实现消息的分流处理，例如生产者生产的消息，header可能都是不尽相同的，这样我们就可以编写两个或多个消费者，对不同header的消息进行针对性的处理。SpringCloudStream实现消息过滤的方式主要有三种，一是使用@StreamLi
分类：
编程语言 时间：
2019-08-11 18:59:07
阅读次数：
167
大家伙周末愉快，小乐又来给大家献上技术大餐。上次是说到了Java多线程的创建和状态|乐字节，接下来，我们再来接着说Java多线程-同步:synchronized 和线程通信:生产者消费者模式。 一、同步:synchronized 多个线程同时访问一个对象，可能造成非线程安全，数据可能错误，所谓同步: ...
分类：
编程语言 时间：
2019-08-11 15:36:26
阅读次数：
141
