博客首页 → MQ

最新文章列表

ActiveMQ使用笔记（八）使用过程中出现的问题

1、消息文件越来越多，导致超出了存储空间 报错日志：Usage Manager Store is Full, 100% of 1073741824. Stopping producer (ID:db01-48754-1336034955132-0:5:1:1) to prevent flooding queue://queue.land.group. See http://activemq.a ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有1699人浏览 2014-03-01 12:37

ActiveMQ使用笔记（七）ActiveMQ性能优化

ActiveMQ使用笔记（七）ActiveMQ性能优化   1、目标策略 在节点destinationPolicy配置策略，可以对单个或者所有的主题和队列进行设置，使用流量监控，当消息达到memoryLimit的时候，ActiveMQ会减慢消息的产生甚至阻塞，destinationPolicy的配置如下： <destinationPolicy> <policy ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有2902人浏览 2014-03-01 12:36

ActiveMQ使用笔记（六）ActiveMQ主备配置

ActiveMQ使用笔记（六）ActiveMQ主备配置 ActiveMQ的主备有三种方式：纯Master/Slave、文件共享方式、数据库共享方式。 1、纯Master/Slave 这种方式的主备不需要对Master Broker做特殊的配置，只要在Slave Broker中指定他的Master就可以了，指定Master有两种方式，最简单的配置就是在broker节点中添加 masterConn ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有2737人浏览 2014-03-01 12:36

ActiveMQ使用笔记（五）ActiveMQ负载均衡

ActiveMQ使用笔记（五）ActiveMQ负载均衡   ActiveMQ可以实现多个mq之间进行路由，假设有两个mq，分别为brokerA和brokerB，当有一条消息发送到 brokerA的队列test中，有一个客户端连接到brokerB上，并且要求获取test队列的消息时，brokerA中队列test的消息就会路由 到brokerB上，反之brokerB的消息也会路由到brokerA ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有2069人浏览 2014-02-26 10:26

ActiveMQ使用笔记（四）ActiveMQ配置安全性

ActiveMQ使用笔记（四）ActiveMQ配置安全性   监视ActiveMQ的方式有多种，在第一部分中已经说到了Web监视控制台，设置登录用户名和密码，这里再说一下JMX监控。运行了ActiveMQ之后，再运行jdk自带的jconsole即可以看到ActiveMQ的进程，如图：   点击连接之后就可以看到ActiveMQ的运行情况。默认情况下是不需要用户名和口令的，修改active ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有2800人浏览 2014-02-26 10:15

ActiveMQ使用笔记（三）ActiveMQ消息发送与接收

ActiveMQ使用笔记（三）ActiveMQ消息发送与接收   配置完了持久化之后，我们就可以使用代码来发送和接收ActiveMQ中的消息了，我这里配置的持久化是KahaDB。 需要导入的jar包： 一段发送消息的代码： public static void send(){ try { // 创建一个连接工厂 String ...
MQJavaActiveMQ 
zyjustin9 评论(0) 有3036人浏览 2014-02-26 10:15

ActiveMQ使用笔记（二）ActiveMQ消息持久化

  ActiveMQ使用笔记（二）ActiveMQ消息持久化 在broker中设置属性persistent=”true”(默认是true)，同时发送的消息也应该是persitent类型的。ActiveMQ消息持久化有三种方式：AMQ、KahaDB、JDBC。 1、AMQ AMQ是一种文件存储形式，它具有写入速度快和容易恢复的特点。消息存储在一个个文件中，文件的默认大小为32兆，如果一条消 ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有4038人浏览 2014-02-26 10:14

ActiveMQ使用笔记（一）ActiveMQ的安装

  ActiveMQ使用笔记（一）ActiveMQ的安装 安装要求： 部署需要jdk1.5及以上，编译需要jdk1.5（java5）及以上 Java的环境变量（JAVA_HOME）必须设置，即jdk安装的目录，比如c:\Program Files\jsdk.1.6 下载ActiveMQ：http://activemq.apache.org/download.html 解压，如图： ...
JavaMQActiveMQ 
zyjustin9 评论(0) 有1970人浏览 2014-02-26 10:14

Java消息服务（第二版）读书笔记

     1.   消息传送机制基础 近年来，系统的复杂性和先进性增长非常显著，对于系统的可靠性、可伸缩性和灵活性等的要求要比以前要高。为了适应这种对更好更快的系统日益增长的需求，体系结构师、架构师和开发者已经开始利用消息传送机制，作为解决这些复杂问题的一种方式。   尽管近年来JMS API未发生显著的变化，但消息传送机制的使用方式有了很大的变化。解决可靠性和可伸缩性问题，已经广 ...
jmsmq 
brandNewUser 评论(0) 有1850人浏览 2014-02-21 16:44

Linux 上的高可用中间件，第 2 部分: WebSphere MQ

对随需应变计算的成功而言，维持最大限度的系统运行时间变得越来越重要。WebSphere MQ 是一个重要的消息中间件， 可以帮助企业加快向随需应变商务的 ...
中间件MQHA 
john521 评论(0) 有1384人浏览 2014-02-20 09:36

让 ZeroMQ 为 MySQL 提供远程分布式任务处理

昨天写了一篇博文    身份证校验，检查身份证号码输入是否正确http://netkiller-github-com.iteye.com/blog/1997402   很多人担心性能问题，我后来想用C写一个扩展，还会有人说影响性能，一不做二不休，干脆mq到远程，通过负载均衡解决。   这里只是提供了一个 mysql 与 ZeroMQ 通信的插件，我并没有将身份证校验程序写出来。不过M ...
netkillermysqlzeromqmqsocket 
netkiller.github.com 评论(0) 有2343人浏览 2013-12-31 11:30

rabbitmq学习10:使用spring-amqp发送消息及异步接收消息

前面我们已经学习了发送消息及同步接收消息的例子了。下面我们来看看如何通过Spring配置来实现异步接收消息。    现在我们建立两个WEB项目。发送消息的项目命名为”rabbitmq-demo-producer“ ，异步接受的消息项目名称”rabbitmq-demo-consumer“。   下面来看看rabbitmq-demo-producer项目中发送信息的程序及配置。  Messag ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有4538人浏览 2013-12-26 14:58

rabbitmq学习9:使用spring-amqp发送消息及同步接收消息

通过对spring-amqp看重要类的认识，下面来通过spring-amqp的发送消息及同步接收消息是如何实现的。有兴趣的朋友 可以去spring-amqp官网下载例子。     先来看看HelloWorldConfiguration类 Java代码   package org.springframework.amqp.helloworld;      import o ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有3977人浏览 2013-12-26 14:57

rabbitmq学习8:spring-amqp的重要类的认识

对于大多数应用来说都做了与spring整合，对于rabbitmq来说。也有与spring的整合。可能通过spring的官网找到spring-amqp项目下载。spring-amqp项目包括三个子项目：spring-amqp、spring-erlang、spring-rabbit.    下面来认识一下spring-amqp中的几个重要类；以spring-amqp-1.0.0.M3版本为例   ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有1905人浏览 2013-12-26 14:57

rabbitmq学习7:ConntectionFactory与Conntection的认知

从前面几小节的学习，我们可能知道在发送和接收消息重要的类ConnectionFactory， Connection，Channel和QueueingConsumer。   ConntectionFactory类是方便创建与AMQP代理相关联的Connection；下面来看看ConntectionFactory是如何创建一个Contention.   首先通过new ConnectionFac ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有1514人浏览 2013-12-26 14:57

rabbitmq学习6:RPC

在《rabbitmq学习2:Work Queues 》中我们已经知道了在多个worker如何分配耗时的任务。如果我现在要在远程的机器上运行然后得到结果，那应当怎么做呢？那就要用到RPC（Remote Procedure Call or RPC ）了！    关于RPC的介绍请参考百度百科里的关于RPC的介绍：http://baike.baidu.com/view/32726.htm#sub ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有1420人浏览 2013-12-26 14:56

数据库进程间通信解决方案

  数据库进程间通信解决方案 数据库与其他第三方应用程序进程间通信解决方案 Mr. Neo Chen (netkiller), 陈景峰(BG7NYT) 中国广东省深圳市龙华新区民治街道溪山美地518131+86 13113668890+86 755 29812080<netkiller@msn.com> $Id: ...
netkillermysqlfifomq 
netkiller.github.com 评论(2) 有2599人浏览 2013-12-16 15:26

rabbitmq学习5:Topics

在前面的《rabbitmq学习4:Routing 》中使用一般的名字的路由，现在想通过一些路由规则让消费者来接受符合规则的消息？那应当怎么样呢？那就要用到类型为topic的Exchange了。 Topics的工作示意图如下： 我们可能从图中看到有*和#两个通配符。*表示通配一个词；#表示通配0个或多个词。 下面让我们来看看Topics的程序如何实现的吧! P端的程序如下 ：   ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有1123人浏览 2013-12-10 10:21

rabbitmq学习4:Routing

  在《rabbitmq学习3:Publish/Subscribe 》中已经学习了发送一个消息，所有消费者端都能收到。那现在这节准备介绍通过路由规则来接受生产者端所发送的消费。Routing的工作示意图如下： 对于Routing的示意图与Publish/Subscribe中的示意图区别： 第一：Publish/Subscribe的Exchange的类型为“fanout”,而Routi ...
rabbitmqmqspringjava 
yimeng528 评论(0) 有1414人浏览 2013-12-10 10:20

最近博客热门TAG

Java(141741) C(73643) C++(68602) SQL(64557) C#(59604) XML(59131) HTML(59042) JavaScript(54916) .net(54782) Web(54511) 工作(54116) Linux(50906) Oracle(49861) 应用服务器(43285) Spring(40811) 编程(39452) Windows(39380) JSP(37540) MySQL(37266) 数据结构(36420)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics