经济金融 1. 什么是 需求 ？ 给定时期，任何价格水平上， 消费者 能够负担且愿意购买的该商品数量。 2. 什么是 供给 ？ 给定时期，任何价格水平上， 生产者 能够负担且愿意提供的该商品数量。 3. 什么是 需求量的变动 ？ 保持其他因素不变， 仅由价格 变动引起的该商品 需求数量 的变动。 4 ...
分类：
其他好文 时间：
2019-03-24 09:24:38
阅读次数：
124
JMS（java message service）常用的消息模式有两种：点对点(PTP)和订阅发布(Pub/Sub） Clients A 和 B是消息生产者，以两种不同的目的地向Clients C, D, 和E 发送消息：在clients A, C, 和 D之间的消息是点对点模式，使用这种模式，客户 ...
分类：
其他好文 时间：
2019-03-22 16:42:29
阅读次数：
149
void test() { int count = 0; // 临界资源区 var queue = new BlockingCollection<string>(); // 生产者线程 Task.Factory.StartNew(() => { while (true) { queue.Add("v ...
启动kafka： bin/kafka-server-start.sh config/server.properties & 停止kafka： bin/kafka-server-stop.sh 创建topic bin/kafka-topics.sh --create --zookeeper local ...
分类：
其他好文 时间：
2019-03-21 11:54:40
阅读次数：
173
碰到的问题 （1）线程操作问题，因为单机节点，代码加锁就好了，后续再写 （2） 消费者写hdfs的时候以流的形式写入，但是什么时候关闭流就是一个大问题了，这里引入了 fsDataOutputStream.hsync(); 生产者 1 package com.xuliugen.kafka.demo; ...
分类：
其他好文 时间：
2019-03-19 15:03:25
阅读次数：
119
最近在学线程,在加上操作系统也在学线程,于是乎有了这篇文章 问题描述: 一群生产者进程在生成产品,并将这些产品提供给消费者进程去消费. 他们之间有一个公共的缓冲区用来存放产品,当产品为空时消费者不能消费,当产品为满时生产者不能生产 CPP实现 利用mutex 互斥量 来对缓存区的操作进行加锁 C++ ...
分类：
系统相关 时间：
2019-03-19 01:02:36
阅读次数：
197
引入 RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。 rabbitMQ是一款基于AMQP协议的消息中间件，它能够在应用之间提供可靠的消息传输。在易用性，扩展性，高可用性上表现优秀。使用消息中间件利于应用之间的解耦，生产者（客户端）无需知道消费者（服务端）的存在。而且两端 ...
分类：
编程语言 时间：
2019-03-18 22:30:50
阅读次数：
252
1 线程同步 1.1 线程安全 java允许多线程并发控制，当多个线程同时操作一个可共享资源变量时（如对其进行增删改查操作），会导致数据不准确，而且相互之间产生冲突。所以加入同步锁以避免该线程在没有操作完共享资源前其他线程操作共享资源，从而保证该变量的唯一性和准确性。 不同步会发生什么问题？在介绍同 ...
分类：
编程语言 时间：
2019-03-18 11:46:34
阅读次数：
172
1、消息投递服务 RabbitMQ是一种消息投递服务,怎么理解这句话呢?即RabbitMQ即不是消息的生产者,也是消息的消费者.他就像现实生活中快递模式,消费者在电商网站上下单买了一件商品,此时对应的生产者(商家)则生产了一件货物(概念上的生产,可能已经生产好了),接着生产者(商家)将货物发送给快递 ...
分类：
Web程序 时间：
2019-03-17 20:08:10
阅读次数：
188
先学习一下RabbitMQ中的六种队列，只学习前五种，具体的官方文档地址是：http://next.rabbitmq.com/getstarted.html 导入maven依赖： 一、简单队列 1、图示 P：消息的生产者 C：消息的消费者 红色：队列 生产者将消息发送到队列，消费者从队列中获取消息。 ...
分类：
其他好文 时间：
2019-03-17 01:24:38
阅读次数：
188
