`
IXHONG
  • 浏览: 450036 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论
文章列表
http://shift-alt-ctrl.iteye.com/blog/2034440 (laoda.toutiao.im)   前言     从本文中你可以得到如下几个问题的解答:     1) 设定消息的时间戳有什么作用     2) 消息的timeToLive与过期原理     3) Producer同步、异步发送消息,以及调优     4) 消息priority与顺序,以及其中的误解。       Producer作为ActiveMQ的消息发送端,是开发工程师经常需要面对的,我们需要多了解一些Producer的特性,以便开发出更高效的应用。       如下为典 ...
http://shift-alt-ctrl.iteye.com/blog/2378868 (laoda.toutiao.im)   ActiveMQ是最常用、特性最丰富的消息中间件,通常用于消息异步通信、调用解耦等多种场景,是JMS规范的实现者之一。   一、架构设计概要     ActiveMQ提供两种可供实施的架构模型:“M-S”和“network bridge”;其中“M-S”是HA方案,“网络转发桥”用于实现“分布式队列”。       1、M-S     Master-Slave模型下,通常需要2+个ActiveMQ实例,任何时候只有一个实例为Master,向Clie ...
http://shift-alt-ctrl.iteye.com/blog/2035321 (laoda.toutiao.im)   前言     从本文中你可以了解到如下内容:     1) consumer端消息消费的模型,session的运作机制     2) 如果提升broker和consumer端消息消费的速率     3) selector,group,exclusive对消息消费的影响     4) 如何让Priority更好的运行,提高消息的顺序性     5) Slow Consumer的产生原因,以及如何调优。         Consumer作为Ac ...
备注:1.如果您此前未接触过RocketMQ,请先阅读附录部分,以便了解RocketMQ的整体架构和相关术语2.文中的MQServer与Broker表示同一概念  分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件,需要具有高吞吐量、高可用等特点。而谈到消息系统的设计,就回避不了两个问题:    1消息的顺序问题  2消息的重复问题  RocketMQ作为阿里开源的一款高性能、高吞吐量的消息中间件,它是怎样来解决这两个问题的?RocketMQ 有哪些关键特性?其实现原理是怎样的?  关键特性以及其实现原理  一、顺序消息  消息有序指的是一类消息消费时,能按照发送的顺序来消费。例如:一 ...
【git 删除本地分支】 git branch -D br   【git 删除远程分支】 git push origin :br  (origin 后面有空格)   git代码库回滚: 指的是将代码库某分支退回到以前的某个commit id 【本地代码库回滚】: git log git reset --hard commit-id :回滚到commit-id,将commit-id之后提交的commit都去除 git reset --hard HEAD~3:将最近3次的提交回滚   【远程代码库回滚】:

cron表达式详解

Cron表达式是一个字符串,字符串以5或6个空格隔开,分为6或7个域,每一个域代表一个含义,Cron有如下两种语法格式:  Seconds Minutes Hours DayofMonth Month DayofWeek Year或 Seconds Minutes Hours DayofMonth Month DayofWeek 每一个域可出现的字符如下: Seconds:可出现", - * /"四个字符,有效范围为0-59的整数 Minutes:可出现", - * /"四个字符,有效范围为0-59的整数 Hours:可出现", - * ...
 现在很多web项目是前后端分离的,后端程序员想在本地通过页面测试接口时有些不方便,这时我们可以利用nginx,将静态请求直接转到线上,将接口请求转到本地。  下载nginx windows版本,解压后在conf目录下新建自己的配置toutiao.conf server { listen 8088; server_name www.toutiao.im; location / { root html; index index.html index.htm; ...
http://blog.csdn.net/xiamizy/article/details/41521025 近期对两个应用进行改造,在上线过程中出现一系列问题(其中一部分是由于ObjectId误区导致的) 先来了解下ObjectId:   TimeStamp  前 4位是一个unix的时间戳,是一个int类别,我们将上面的例子中的objectid的前4位进行提取“4df2dcec”,然后再将他们安装十六进制 专为十进制:“1307761900”,这个数字就是一个时间戳,为了让效果更佳明显,我们将这个时间戳转换成我们习惯的时间格式(精确到秒)   $ date -d ...
  可能很多人会问为何要用mongodb存储图片和文件,我的理由是mongodb作存储方便稳定易扩展,我们自己写的文件存储服务器肯定很LOW,除了含有巨量图片的大型系统,一般由公司自研图片存储外,大部分情况下,我们用mongodb足以应付。另外,很多人根本就不知道或者没尝试过用mongodb存储文件,而对方还故意问我为什么用这个。本文特此奉上代码并提供MongoDBClient与spring的集成。   whatsmars-common |-src |-main |-java |-com.itlong.whatsmars.commo ...

rocketmq demo

    博客分类:
  • MQ
首先下载rocketmq,启动需要指定rocketmq home目录 cd github git clone -b develop https://github.com/apache/incubator-rocketmq.git   whatsmars-mq |-src |-main |-java |-com.itlong.whatsmars.mq.rocketmq.quickstart BrokerStartup.java Consumer.java NamesrvStartup.java Produc ...
 Redis客户端简单封装并集成spring. spring-data-redis对redis有过度封装的嫌疑,而且也没有提供sharding模式,本文遂简单封装jedis。   <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance&quo ...
RocketMQ的并发读写能力扛住了2016年双十一,每秒17.5万笔订单的创建(单笔订单衍生出N条消息,实际tps是17.5*n 万),下面对其高并发读写原理进行探讨。主要体现在两方面:客户端收发消息,服务器接收消息并持久化(重点) ...
RocketMQ是一个分布式开放消息中间件,底层基于队列模型来实现消息收发功能。RocketMQ集群中包含4个模块:Namesrv, Broker, Producer, Consumer。 Namesrv: 存储当前集群所有Brokers信息、Topic跟Broker的对应关系。 Broker: 集群最核心模块, ...

你好,RocketMQ

    博客分类:
  • MQ
http://rocketmq.apache.org/ 编者按 这些年开源氛围越来越好,各大IT公司都纷纷将一些自研代码开源出来。2012年,阿里巴巴开源其自研的第三代分布式消息中间件——RocketMQ。经过几年的技术打磨,阿里称基于RocketMQ技术,目前双十 ...
服务消费方发起请求   当服务的消费方引用了某远程服务,服务的应用方在spring的配置实例如下:   <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />   demoService实例其实是代理工厂生产的代理对象(大家可以参考代理那部分生成的伪代码),在代码中调用demoService.sayHello(“world!”)时,   1.      将方法名方法参数传入InvokerInvocationHand ...
Global site tag (gtag.js) - Google Analytics