Kafka简介kafka是一个高吞吐量的分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力，通常用于大数据及流处理平台。消息队列里都有生产者/消费者的概念，生产者往队列里写消息，而消费者则是从队列里获取消息。一般在架构设计中起到解耦、削峰、异步处理的作用。kafka对外使用topic的概念，生产者往topic里写消息，消费者则从topic里读消息。为了做到水平扩展，一个topic实际是由
分类：
其他好文 时间：
2018-10-25 19:45:36
阅读次数：
190
一、生产者消费者模型 在线程世界里，生产者就是生产数据的线程，消费者就是消费数据的线程。在多线程开发当中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。为了解决这个问题于是引入 ...
分类：
其他好文 时间：
2018-10-25 19:45:01
阅读次数：
204
前言： 在生产环境中，我们不可能将每个服务的真实信息暴漏出去，因为这样太不安全。 我们会选择使用路由代理真实的服务信息，由它负责转发给真实的服务。 新建一个Zool： 1.添加依赖 2.修改配置 3.开启注解 测试： 开启eureka7001、服务生产者8001、路由zool9090 1.访问Eur ...
分类：
编程语言 时间：
2018-10-25 19:30:29
阅读次数：
138
在前面我们将了很多关于同步的问题，然而在现实中，需要线程之间的协作。比如说最经典的生产者-消费者模型：当队列满时，生产者需要等待队列有空间才能继续往里面放入商品，而在等待的期间内，生产者必须释放对临界资源（即队列）的占用权。因为生产者如果不释放对临界资源的占用权，那么消费者就无法消费队列中的商品，就 ...
分类：
编程语言 时间：
2018-10-25 15:41:21
阅读次数：
210
对于RibbitMQ 消息队列 使用： 定义一个队列，作为消息队列 生产者，生产消息添加入队列 消费者，监听到消息队列中有消息后，取出消息处理消息 每台服务器也可以配置多个消费者去处理消息 此处向Handler中，增加的消费者对象，类似于观察者模式 那是不是可以改为， Handler 中，持有消费者 ...
分类：
其他好文 时间：
2018-10-25 12:10:46
阅读次数：
244
主要内容: 一. 锁 二. 信号量 三. 事件 通过event来完成红绿灯模型 四. 队列(重点) 队列实现进程间的通信 五. 生产者消费者模型 1. 初始版本(程序会阻塞住) 2. 升级版本一(通过抛出异常信号的方式结束进程) 3. 升级版本二(通过发送结束信号的方式结束进程) 第一种: 生产者发 ...
分类：
编程语言 时间：
2018-10-25 00:36:58
阅读次数：
199
通过三个工程演示整合过程 工程一：API工程：服务端与客户端共同需要引入的工程 pom:无特殊依赖，下边内容供服务端与客户端引用此工程使用 实体类: API: 工程二：生产者工程：服务端 pom dubbo必须依赖项：（使用zk） application.yml：配置dubbo配置项 工程三：消费者 ...
分类：
编程语言 时间：
2018-10-24 22:13:15
阅读次数：
223
理解此篇请先看http://www.cnblogs.com/haiyan123/p/7445584.html """多线程下生产者消费者模型。定义：在同一进程，同一主线程下， 采用多线程完成多个任务的同时，各自数据保持干净整洁。即、花最少的时间 完成最多的任务""" import threading ...
分类：
编程语言 时间：
2018-10-24 19:57:33
阅读次数：
131
(1)锁:进程之间数据不共享,但是共享同一套文件系统,所以访问同一个文件,或同一个打印终端,是没有问题的，而共享带来的是竞争，竞争带来的结果就是错乱，如何控制，就是加锁处理。 虽然使用加锁的形式实现了顺序的执行，但是程序又重新变成串行了，这样确实会浪费了时间，却保证了数据的安全。 (Lock) im ...
分类：
编程语言 时间：
2018-10-24 17:52:05
阅读次数：
302
今天要谈的主题是关于求职，求职是在每个技术人员的生涯中都要经历多次。对于我们大部分人而言，在进入自己心仪的公司之前少不了准备工作，有一份全面细致面试题将帮助我们减少许多麻烦。在跳槽季来临之前,特地做这个系列的文章，一方面帮助自己巩固下基础，另一方面也希望帮助想要换工作的朋友。 相关概念 面向对象的三 ...
分类：
编程语言 时间：
2018-10-22 22:13:16
阅读次数：
199
