Symphony开发过程
DE：
1. . profile.platform
2. soamstartup & (DE only)
3. 编译工程
4. cat app.xml | grep package
5. cat app.xml | grep consumer
6. soamdeploy add package_na...
分类：
其他好文 时间：
2015-04-07 12:04:48
阅读次数：
117
1、topic与virtual topic的区别topic是把一份消息广播给多个客户端，但对于接收这个topic的客户端来说，只能有一个consumer消费这个topic，不能并行消费（而queue可以用多个consumer来并行消费）。virtual topic也是广播消息给多个客户端，但对于客户...
分类：
其他好文 时间：
2015-04-02 20:43:36
阅读次数：
186
架构
(#)
节点角色说明：
Provider: 暴露服务的服务提供方。Consumer: 调用远程服务的服务消费方。Registry: 服务注册与发现的注册中心。Monitor: 统计服务的调用次调和调用时间的监控中心。Container: 服务运行容器。
调用关系说明：
0. 服务容器负责启动，加载，运行服务提供者。1. 服务提供者在启动时，向注册中心注册自己提供的服务。...
分类：
其他好文 时间：
2015-03-31 22:23:48
阅读次数：
210
package com.cn.test3; //java多线程模拟生产者消费者问题//ProducerConsumer是主类，Producer生产者，Consumer消费者，Product产品//Storage仓库//批注：我把输出结果写在程序以下了，你能够看一下，事实上非常easy的，你想象一下产...
分类：
编程语言 时间：
2015-03-31 12:41:24
阅读次数：
176
我们已经对提供者示例进行了详细的阐述,接下来的消费者相对而言比较简单.
1
配置相关pom.xml信息,跟提供者类似,需要相关环境的java包应用.
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd...
分类：
其他好文 时间：
2015-03-31 00:55:33
阅读次数：
209
本文介绍了Kafka的创建背景，设计目标，使用消息系统的优势以及目前流行的消息系统对比。并介绍了Kafka的架构，Producer消息路由，Consumer Group以及由其实现的不同消息分发方式，Topic & Partition，最后介绍了Kafka Consumer为何使用pull模式以及K...
分类：
其他好文 时间：
2015-03-29 19:20:03
阅读次数：
226
生产者消费者问题（Producer-consumer problem）：生产者不断地生产产品，消费者取走生产者生产的产品。生产者生产出产品后将其放到一个区域之中，消费者从这个地方去除数据。
涉及的问题：要保证生产者不会在缓冲区满时加入数据，消费者也不会在缓冲区中空时消耗数据。
主要涉及：多线程的同步问题。
1、假设生产者线程刚向数据存储空间添加了产品的名称，还没有添加产品的内容，程序就切到了消费者的线程，消费这的 线程将吧产品的名称和上...
分类：
编程语言 时间：
2015-03-20 12:56:18
阅读次数：
172
通观全部Dubbo代码，有两个很重要的对象就是Invoker和Exporter，Dubbo会根据用户配置的协议调用不同协议的Invoker，再通过ReferenceFonfig将Invoker用Exporter包装后暴露在网络上。当用户调用一个Service接口的一个方法后由于Dubbo使用javassist动态代理，会调用Invoker的Invoke方法从而初始化一个RPC调用访问请求访问服务端...
分类：
其他好文 时间：
2015-03-19 00:54:58
阅读次数：
832
最近做的一个项目需要跟Kafka打交道，学习了很多相关知识，就到这里来汇总一下。kafka是一个传递消息的系统，原本是用来快速记录海量log的，现在也经常用作消息队列。它主要由三个部分组成，producer，broker以及consumer。producer发布消息，broker存储消息，consu...
分类：
其他好文 时间：
2015-03-14 06:05:48
阅读次数：
147
原文：https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
为什么使用High Level Consumer
在某些应用场景，我们希望通过多线程读取消息，而我们并不关心从Kafka消费消息的顺序，我们仅仅关心数据能被消费就行。High Level 就是用于抽象这类消费动作的。
消息消费已C...
分类：
其他好文 时间：
2015-03-13 18:53:10
阅读次数：
141
