rabbitmq作为消息队列可以有消息消费确认机制,redis的list结构可以简单充当消息队列,但不具备消费确认机制,随意关停程序,会丢失一部分正在程序中处理但还没执行完的消息。 使用rabbitmq的最常用库pika ...
分类:
编程语言 时间:
2018-12-19 15:54:26
阅读次数:
887
关于 Topic 和 Partition: Topic: 在 kafka 中,topic 是一个存储消息的逻辑概念,可以认为是一个消息集合。每条消息发送到 kafka 集群的消息都有一个类别。物理上来说,不同的 topic 的消息是分开存储的,每个 topic 可以有多个生产者向它发送消息,也可以有 ...
分类:
其他好文 时间:
2018-12-19 15:40:08
阅读次数:
804
摘要:对制造企业来说,在生产和工厂侧,它以规模化、标准化、自动化为基础,但它还需被赋予柔性化、定制化、可视化、低碳化的新特性;在商业模式侧,会出现颠覆性的变化——生产者影响消费者的模式被消费者需求决定产品生产的模式取而代之。智能工厂请添加链接描述是一次深刻的升级,会让研发、生产、产品、渠道、销售、客户管理等一整条生态链为之发生剧变。对制造企业来说,在生产和工厂侧,它以规模化、标准化、自动化为基础,
分类:
其他好文 时间:
2018-12-19 14:13:02
阅读次数:
168
协程的优点: 协程是进程和线程的升级版,进程和线程都面临着内核态和用户态的切换问题而耗费许多切换时间, 而协程就是用户自己控制切换的时机,不再需要陷入系统的内核态。协程的执行效率非常高。因为子程序切换不是线程切换,而是由程序自身控制。因此,没有线程切换的开销,和多线程相比,线程数量越多,相同数量的协 ...
分类:
编程语言 时间:
2018-12-18 19:43:03
阅读次数:
197
概览本文主要介绍如何使用RabbitMQ消息代理来实现分布式系统之间的通信,从而促进微服务的松耦合。RabbitMQ,也被称为开源消息代理,它支持多种消息协议,并且可以部署在分布式系统上。它轻量级,便于部署应用程序。它主要充当一个队列,其中输入的消息可以首先被操作。RabbitMQ可以在许多操作系统和云环境中运行,并为大多数流行语言提供了广泛的开发工具。它是生产者-消费者模式,生产者发出信息,消费
分类:
其他好文 时间:
2018-12-17 16:53:38
阅读次数:
175
1. kafka官网提供测试脚本 (1) 生产者测试脚本kafka-producer-perf-test.sh 参数说明: --topic topic名称, --num-records 总共需要发送的消息数, --record-size 每个记录的字节数, --throughput 每秒钟发送的记录 ...
分类:
其他好文 时间:
2018-12-17 11:42:09
阅读次数:
197
与上一篇《秒杀多线程第十篇 生产者消费者问题》的生产者消费者问题一样,读者写者也是一个非常著名的同步问题。读者写者问题描述非常简单,有一个写者很多读者,多个读者可以同时读文件,但写者在写文件时不允许有读者在读文件,同样有读者在读文件时写者也不去能写文件。 上面是读者写者问题示意图,类似于生产者消费者 ...
分类:
编程语言 时间:
2018-12-17 11:31:17
阅读次数:
175
.创建注册中心Eureka 2.创建服务提供者 provider 3.创建服务消费者 customer(用feign调用生产者:) 4.执行命令 生成jar包 clean install -DskipTests 5.构建镜像并启动 6.服务器结构图如下 7.启动: docker-compose up ...
分类:
编程语言 时间:
2018-12-16 19:35:10
阅读次数:
278
Maven 配置文件 provider 生产者代码 Consumer 消费者 Constants 常量类 ...
分类:
其他好文 时间:
2018-12-16 18:12:27
阅读次数:
123
Java实现生产者消费者的方式有:wait && notify、BlockingQueue、Lock && Condition等 wait、notify注意事项:(1)可以使用wait()和notify()方法在Java中实现线程间通信。不只是一个或两个线程,而是多个线程可以使用这些方法相互通信。( ...
分类:
其他好文 时间:
2018-12-15 17:24:19
阅读次数:
201