javafu
- 浏览: 53507 次
- 性别:
- 来自: 北京
-
最新评论
文章列表
ActiveMQ两种消息模式
- 博客分类：
- ActiveMQ
一、点对点模式(p2p)
二、发布/订阅模式(pub/sub)
示例：
public class Producer {
// 建立connectionFactory工厂对象
private ActiveMQConnectionFactory connectionFactory;
// 连接对象
private Connection connection;
// session对象
private Session session;
// 生产者
private MessageProducer producer;
public Produc ...
ActiveMQ消息选择器与异步接收
- 博客分类：
- ActiveMQ
一、消息选择器
消息选择器：过滤消息属性与设置条件相等的消息进行消费。语义与sql一致。
private final String selector_1 = "sex='w'";
this.consumer = session.createConsumer(destination, selector_1);
二、消息异步接收
消息异步接收 ：当消息到达时，ActiveMQ主动通知消费端，可以注册一个MessageListener类实现onMessage方法，监听MQ送达消息
示例：
public class Produ ...
ActiveMQAPI
- 博客分类：
- ActiveMQ
一、connection方法使用
1、创建connection时，它的传输默认是关闭的，必须使用start方法开启。一个connection可以创建多个session。
2、当一个程序执行完成后，必须关闭之前创建的connection,否则ActiveMQ不能释放资源。关闭Connection后，同时也关闭了Session\MessageProducer\MessageConsumer.
Connection connection = connectionFactory.createConnection();
Connection connection = ...
ActiveMQ持久化存储
- 博客分类：
- ActiveMQ
activeMQ的消息可以存储在不同的存储中，（默认是kahaDB,levelDB,mysql,oracle）
1、配置数据库连接
C:\M\apache-activemq-5.14.1\confactivemq.xml添加数据库连接数据。
1、1替换数据库连接
<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#mysqlDB"/>
...
ActiveMQ配置文件及安全验证机制
- 博客分类：
- ActiveMQ
1、修改控制台登录用户密码
activemq的web管理界面：http://127.0.0.1:8161/admin
activemq管控台使用jetty部署，需要修改密码则修改对应的配置文件C:\M\apache-activemq-5.14.1\conf\jetty-realm.properties
引用
admin: admin, admin
user: user, user
2、消息安全机制：只有符合认证的用户才能进行发送和获取消息
2.1 到C:\M\apache-activemq-5.14.1\confactivemq.xml添加安全 ...
ActiveMQ使用之HelloWord
- 博客分类：
- ActiveMQ
一、下载MQ:
官网http://activemq.apache.org/下载,选择windows版本学习，项目当中使用linux版本进行集群。
二、解压目录介绍
Bin:启动脚本.bin/activemq.bat是启动MQ的脚本
Conf：mq核心配置。
activemq.xml核心配置
Jetty:管控 ...
ActiveMQ概述及其它消息中间件对比
- 博客分类：
- ActiveMQ
一、概述
作用：异步消费数据，异步发邮件，异步查询操作
当前远程调用等许多框架rpc技术广泛应用，但面对大规模和复杂度都越来越高的分布式系统，这些技术有以下局限性：
1、同步通信：客户发出调用后，必须 ...
一、ITridentSpout
基于事务
static interface ITridentSpout.BatchCoordinator<X>
static interface ITridentSpout.Emitter<X>
接口类的实现和之前事务ITransactionalSpout 非常类似。
二、调用链用于执行多个聚合
topology.newDRPCStream("top", drpc).each(new Fields("args"), new Split(“ ”), new Fiel ...
Trident实战之计算网站PV
- 博客分类：
- Strom
1、Trident实战之计算网站PV
/**
* Trident实战之计算网站PV
*/
public class TridentPVTopo {
public static StormTopology buildTopology(LocalDRPC drpc) {
Random random = new Random();
String[] hosts = { "www.taobao.com" };
String[] session_id = { "ABYH6Y4V4SCVXTG6DPB4VH9U123", ...
Trident API和概念
- 博客分类：
- Strom
一、Trident API——Spout
ITridentSpout:最通用的Spout，可以支持事务或者不透明事务语义。
IBatchSpout: 一个非事务spout 。
IPartitionedTridentSpout: 分区事务spout，从数据源(比如一个Kafka集群)读分区数据
IOpaquePartitionedTridentSpout:不透明分区事务spout，从数据源读分区数据
接口变动
例如：
简单概括总体流程就是：
trident在执行时每批先调用 getPartitionsForBatch()如果发现返回的Partit ...
英文原址：https://github.com/nathanmarz/storm/wiki/Trident-tutorial
翻译地址1：http://blog.csdn.net/derekjiang/article/details/9126185#t3
翻译地址2：http://www.tuicool.com/articles/B3yA3aI
Trident是完全容错的，拥有有且只有一次处理的语义，其实就是transactional的高级封装。这就让你可以很轻松的使用Trident来进行实时数据处理。Trident会把状态以某种形式保持起来，当有错误发生时，它会根据需要来恢复这些状态。
...
1、spout
public class MyOpaquePtTxSpout implements IOpaquePartitionedTransactionalSpout<MyMata> {
/**
* 将Coordinator发射数据动作下放到emitPartitionBatch类执行。
*/
private static final long serialVersionUID = 1L;
public static int BATCH_NUM = 10;
public Map<Integer, Map<Long, String ...
分布式远程调用drpc实例
- 博客分类：
- Strom
一、DRPC定义
分布式dRPC（distributed RPC，DRPC）用于对Storm上大量的函数调用进行并行计算。
对于每一次函数调用，Storm集群上运行的拓扑接收调用函数的参数信息作为输入流，并将计算结果作为输出流发射出去。
一句话概括：Storm进行计算，根据客户端提交的请求参数，而返回Storm计算的结果。
DRPC通过DRPC Server来实现，DRPC Server的整体工作过程如下：
接收到一个RPC调用请求；
发送请求到Storm上的拓扑；
从Storm上接收计算结果；
将计算结果返回给客户端。
注：在client客户端看来，一个DRPC调用看起来和一般的RPC调用 ...