1 推荐系统概念 1.1推荐系统的目的和作用 随着信息技术和互联网的发展，人们逐渐从信息匮乏的时代走入了信息过载（information overload）的时代。 在这个时代，无论是信息消费者还是信息生产者都遇到了很大的挑战：作为信息消费者，如何从大量信息中找到自己感兴趣的信息是一件非常困难的事情 ...
分类：
其他好文 时间：
2020-11-01 22:03:32
阅读次数：
21
引言所谓的消费语义，指的就是如下三种情况如何保证消息最多消费一次如何保证消息至少消费一次如何保证消息恰好消费一次其实类似还有一个投递语义如何保证消息最多投递一次如何保证消息至少投递一次如何保证消息恰好投递一次说句实在话，其实还是老问题，只是换了一种问法！OK,开始我们的正文正文我们先做如下约定Producer代表生产者Consumer代表消费者MessageQueue代表消息队列投递语义我们先从投
分类：
其他好文 时间：
2020-11-01 21:04:16
阅读次数：
14
本文将学习Kafka生产者的使用和原理，文中使用的kafka-clients版本号为2.6.0。下面进入正文，先通过一个示例看下如何使用生产者API发送消息。publicclassProducer{publicstaticvoidmain(String[]args){//1.配置参数Propertiesproperties=newProperties();properties.put("boots
分类：
其他好文 时间：
2020-11-01 09:31:55
阅读次数：
17
前言相信经过前面几篇之后，大家已经对Dubbo整体流程已经清晰了，包括服务是如何暴露的，服务是什么时候注册到注册中心的，以及服务是怎么引入的，服务整体的调用过程等等。不过还有一个很重要的点没有深入的讲过，就是Dubbo的集群容错功能。线上的服务肯定都是集群部署的，至少得来个两台，互相做backup，那么问题来了，服务消费者要选用哪一台提供者进行调用呢？调用失败了怎么办呢？这时候集群容错功能就派上用
分类：
其他好文 时间：
2020-10-31 02:07:57
阅读次数：
15
在《Kafka消费者的使用和原理》中已经提到过“再均衡”的概念，我们先回顾下，一个主题可以有多个分区，而订阅该主题的消费组中可以有多个消费者。每一个分区只能被消费组中的一个消费者消费，可认为每个分区的消费权只属于消费组中的一个消费者。但是世界是变化的，例如消费者会宕机，还有新的消费者会加入，而为了应对这些变化，让分区所属权的分配合理，这都需要对分区所属权进行调整，也就是所谓的“再均衡”。本文将对再
分类：
其他好文 时间：
2020-10-27 11:55:04
阅读次数：
42
继上周的《Kafka生产者的使用和原理》，这周我们学习下消费者，仍然还是先从一个消费者的HelloWorld学起：publicclassConsumer{publicstaticvoidmain(String[]args){//1.配置参数Propertiesproperties=newProperties();properties.put("key.deserializer","org.apac
分类：
其他好文 时间：
2020-10-27 11:53:49
阅读次数：
25
在上篇文章《消息系统概述》中对消息系统进行了介绍，本次将学习Kafka中的基本概念。首先我们回顾下在消息系统的使用场景中有三种角色分别是生产者、消息系统和消费者，其中生产者负责产生消息和发送消息到消息系统，而消息系统将为消费者提供消息用于处理，如下图。Kafka是基于发布/订阅模式的消息系统，如下图。生产者会将消息推送到Kafka中的某个Topic上。引入Topic的目的则是为了对消息进行分类，这
分类：
其他好文 时间：
2020-10-27 11:52:37
阅读次数：
24
产业互联网并不是什么新物种，早在2000年，硅谷的沙利文咨询公司就提出了产业互联网的概念。2012年，通用公司发布了一份名为《产业互联网：打破智慧与机器的边界》的报告，对“产业互联网”重新进行了介绍，让这个概念被人们接受。产业互联网是相对于消费互联网来说的，在产业互联网之前，大量互联网服务都面向消费者展开，在零售、服务、出行、教育等领域为消费者创造了巨大的便利和价值，然而这些市场日趋饱和。产业互联
分类：
其他好文 时间：
2020-10-21 20:52:01
阅读次数：
19
线程通信 为什么要进行线程通信 把一个大的任务放到主线程的话，由于顺序执行，会严重影响程序执行的效率。为了提高效率和并发度，可以将任务解耦为多个线程执行，比如一个线程接收数据，一个线程处理数据，这个时候，线程间就会出现交互，也就是线程通信。 生产者消费者模型 线程通信的关键应用场景就是生产者消费者问 ...
分类：
编程语言 时间：
2020-10-21 20:23:26
阅读次数：
23
前提 在某一次用户标签服务中大量用到异步流程，使用了RabbitMQ进行解耦。其中，为了提高消费者的处理效率针对了不同节点任务的消费者线程数和prefetch_count参数都做了调整和测试，得到一个相对合理的组合。这里深入分析一下prefetch_count参数在RabbitMQ中的作用。 pre ...
分类：
其他好文 时间：
2020-10-18 17:00:49
阅读次数：
69
