博客首页 → metaq

最新文章列表

再说rocketmq消息存储[转]

再说rocketmq消息存储 有空自己全面看一次，给个完整解读 mq:metaq,rocketmq,activitymq,rabbitmq rpc:dubbo seriaxx:hessan,pb, netty nginx redis db:mysql,javadb,derby 数据结构 算法 优化算法 数据处理算法 numpy,panda,sklearn,tensorflow... h ...
mqmetaqrocketmq源码 
gelongmei 评论(0) 有555人浏览 2018-01-09 13:10

consumer在zookeeper中的消费者节点

consumer在zookeeper中的节点配置信息整理    
metaq 
eomseoms 评论(0) 有705人浏览 2015-04-16 23:11

MetaQ技术内幕——源码分析(八)

上一篇以及上上篇基本介绍了MetaQ如何使用Gecko框架在网络上传输数据，今天将继续进一步介绍在Broker，各种命令的处理逻辑（暂时将不涉及到事务处理 ...
MetaQ 
wbj0110 评论(0) 有805人浏览 2014-06-01 10:36

MetaQ技术内幕——源码分析(七)

前面介绍了Broker在网络传输过程中使用的数据结构，同时也介绍了MetaQ使用了Gecko框架作为网络传输框架。 有人会问，Gecko什么调用MetaEncodeCommand的encode()方法，让命令变成可见的明文在网络传输，Gecko又在什么时候将网络传输的数据包装成一个个Command对象？ 或许有人已经注意到了笔者在介绍Broker启动类MetaMorphosisBroker的 ...
MetaQ 
wbj0110 评论(0) 有2008人浏览 2014-05-31 14:03

MetaQ技术内幕——源码分析(六)

前面介绍过MetaQ使用gecko框架作为网络传输框架，Gecko采用请求/响应的方式组织传输。MetaQ依据定义了请求和响应的命令，由于命令Client和Broker均需要使用，所以放在了common工程的类MetaEncodeCommand中： Java代码   public String GET_CMD = "get";  //请求数据请求  public ...
MetaQ 
wbj0110 评论(0) 有758人浏览 2014-05-31 14:03

MetaQ技术内幕——源码分析(五)

Broker接收从Producer(Client端)发送的消息，也能够返回消息到Consumer(Client)，对于Broker来说，就是网络输入输出流的处理。 Broker使用淘宝内部的gecko框架作为网络传输框架，gecko是一个NIO框架，能够支持一下特性： 1、 可自定义协议,协议可扩展、紧凑、高效 2、 可自动管理重连，重连由客户端发起 3、 需进行心跳检测，及时发现连接失 ...
MetaQ 
wbj0110 评论(0) 有585人浏览 2014-05-31 14:02

MetaQ技术内幕——源码分析(四)

前面，我们已经把Broker存储最重要的一个类具体分析了一遍，接下来，我们分析一下其删除的策略。前面介绍过Messagestore采用的多文件存储的组织方式，而存储空间不可能无限大，得有一定的删除策略对其进行删除以腾出空间给新的消息。 MetaQ允许自定义删除策略，需要实现接口DeletePolicy，默认提供了两种删除策略：过期删除（DiscardDeletePolicy）和过期打包删除（A ...
MetaQ 
wbj0110 评论(0) 有806人浏览 2014-05-31 13:24

MetaQ技术内幕——源码分析(三)

前面忘了先介绍一下Broker消息存储的组织方式，我们前面知道了一条消息属于某个Topic下的某个分区，消息存储的组织方式是按照此方式进行组织的，结构图如下：   所以对于每个Topic而言，分区是最小的元素，对外API主要由MessageStore提供，一个MessageStore实例代表一个分区的实例，分区存储具体的内容。在MetaQ中，分区的存储采用的多文件的方式进行组合，即Mes ...
MetaQ 
wbj0110 评论(0) 有900人浏览 2014-05-31 12:45

MetaQ技术内幕——源码分析(二)

消息，是MetaQ最重要的资源，在分析MetaQ之前必须了解的概念，我们所做的一切都是围绕消息进行的，让我们看看MetaQ中消息的定义是怎样的，MetaQ的类Message定义了消息的格式： Java代码  
MetaQ 
wbj0110 评论(0) 有765人浏览 2014-05-30 14:58

MetaQ技术内情——源码分析(一)

MetaQ技术内幕——源码分析(一) 笔者最近在业务上需要使用到MetaQ，也借此阅读了MetaQ的相关源码，准备分享MetaQ源码分析。先扫扫盲，如果读者对MetaQ已经较为熟悉，可以跳过下一段落。   一、MetaQ简介   MetaQ（全称Metamorphosis）是一个高性能、高可用、可扩展的分布式消息中间件，,MetaQ具有消息存储顺序写、吞吐量大和支持本地和XA事务等特 ...
MetaQ 
wbj0110 评论(0) 有1149人浏览 2014-05-30 14:10

简单例子-metaq

示例源码 源码地址： metamorphosis-example Example 消息中间件中有两个角色：消息生产者和消息消费者。Meta里同样有这两个概念，消息生产者负责创建消息并发送到meta服务器，meta服务器会将消息持久化到磁盘，消息消费者从meta服务器拉取消息并提交给应用消费。我们假设你已经部署了你的meta服务器，参见
简单例子MetaQ 
wbj0110 评论(0) 有1004人浏览 2014-04-19 09:28

Java advancetopics-metaq

本指南以1.4.5版本的java客户端为起点编写。 简单例子 消息 客户端配置 会话工厂MessageSessionFactory 发送消息MessageProducer 订阅消息MessageConsumer 遍历消息TopicBrowser Spring框架支持 高级主题 这里包括一些MetaQ的高级应用，比如使用log4j appender发送消息作为日志框架，Tw ...
Java advancetopicsMetaQ 
wbj0110 评论(0) 有994人浏览 2014-04-19 09:27

Metaq服务器端的配置说明server.ini

注：从metaq官网copy下来，便于查看； 地址：https://github.com/killme2008/Metamorphosis/wiki/%E9%85%8D%E7%BD%AE%E7%AE%A1%E7%90%86 配置管理 Web管理平台 从1.4.5开始，MetaQ提供了一个Web管理平台，默认运行在8120端口，你可以通过浏览器访问
metaq 
ghost_face 评论(0) 有1117人浏览 2014-04-04 11:03

磁盘HashMap实现(metaq 索引实现源码)

      /* * (C) 2007-2012 Alibaba Group Holding Limited. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with ...
磁盘HashMapmetaq 
xiangkui 评论(0) 有1587人浏览 2014-02-12 17:28

淘宝MetaQ开源消息队列安装

前提:: 安装zookeeper 首先你需要搭建自己的zookeeper集群，meta利用zookeeper做服务的注册和发现，以及默认情况下offset的存储。 安装java运行环境 第一步：下载安装包从这里下载最新的metamorphosis服务器可运行包并在某个目录解压缩（或者checkout源码按上面的步骤打包出来）。解压出来的结构大概是这样 -你的目录 -taobao -metamor ...
淘宝MetaQ开源消息队列安装MetaQ 
wbj0110 评论(0) 有874人浏览 2014-02-08 09:32

RocketMQ 脚本调优

#!/bin/sh   # # Execute Only Once #   echo 'vm.overcommit_memory=1' >> /etc/sysctl.conf echo 'vm.min_free_kbytes=5000000' >> /etc/sysctl.conf echo 'vm.drop_caches=1' >> / ...
RocketMQMetaQJava 
wbj0110 评论(0) 有1226人浏览 2013-12-05 09:35

MetaQ技术内幕——源码分析(转)

笔者最近在业务上需要使用到MetaQ，也借此阅读了MetaQ的相关源码，准备分享MetaQ源码分析。先扫扫盲，如果读者对MetaQ已经较为熟悉，可以跳过下一段 ...
MetaQ 
wbj0110 评论(1) 有1681人浏览 2013-11-20 09:35

RocketMQ如何安装，需要git、Java、Maven环境

https://github.com/alibaba/RocketMQ/wiki/Quick-Start
RocketMQMetaQJavaMavenGit 
wbj0110 评论(0) 有2011人浏览 2013-11-19 09:37

RabbitMQ和kafka从几个角度简单的对比

业界对于消息的传递有多种方案和产品，本文就比较有代表性的两个MQ(rabbitMQ,kafka)进行阐述和做简单的对比， 在应用场景方面， RabbitMQ,遵循AMQP协议， ...
RabbitMQkafkaMetaQRocketMQJavav 
wbj0110 评论(1) 有9019人浏览 2013-11-15 09:25

RocketMQ WiKi

https://github.com/alibaba/RocketMQ/wiki
RocketMQMetaQJavaWiKi 
wbj0110 评论(0) 有1417人浏览 2013-11-14 09:50

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics