蝶盟紫
- 浏览: 54893 次
-
最新评论
文章列表
mybatis-@Param
- 博客分类：
- mybatis
Mapper.java
List<TInsure> selectInsureByDatePeriodFromRoute(
@Param(value = "startDate")Date startDate,
@Param(value = "endDate")Date endDate);
Mapper.xml
<select id="select" resultMap="BaseResultMap" parameterType="java.util.M ...
当broker开启confirm时，可以添加此监听器。
public void testWaitForConfirms() throws IOException, InterruptedException {
// 创建Channel时开启：channel.confirmSelect();
// 记录客户端发送消息的序号1、2、3、4、。。。 final SortedSet<Long> unconfirmedSet = Collections.synchronizedSortedSet(new Tre ...
转自：http://www.cnblogs.com/rader/archive/2012/06/28/2567779.html
如果你想创建一个只有自己可见的队列，即不允许其它用户访问，RabbitMQ允许你将一个Queue声明成为排他性的（Exclusive Queue）。
该队列的特点是：
只对首次声明它的连接（Connection）可见
会在其连接断开的时候自动删除。
对于第一点，首先是强调首次声明，因为另外一个连接无法声明一个同样的排他性队列；其次是只区别连接（Connection）而不是通道（Channel），从同一个连接创建的不同的通道可以同时访问某一个排 ...
rabbitmq-queueDelete
- 博客分类：
- rabbitmq
当客户端channel把消费者和queue绑定，然后channel再把queue删掉时，这个事件是可以监听到的：
private final String queue = "cancel_notification_queue";
public void testConsumerCancellationNotification() throws IOException, InterruptedException { final BlockingQueue<Boolean> result = new ArrayB ...
参考：http://www.aichengxu.com/view/37900
如果是一个队列只希望一个消费者进行处理，那么定义队列的时候可以指定时独占模式：exclusive
如果是一个队列由多个消费者，但是只希望消息由其中的一个消费者优先进行处理，当这个消费者挂掉的时候，再由其他消费者进行处理的话，可以给消费者设置不同的优先级
从RabbitMQ的3.2版本开始，这个消息代理支持消费者优先级。这个可以通过设置消费者的x-priority进行配置。
spring配置：为了方便，命名空间在listener元素上提供了priority属性：
<rabbit:list ...
rabbitmq-BasicQos
- 博客分类：
- rabbitmq
转自：http://www.cnblogs.com/haoxinyue/archive/2012/10/01/2709644.html
QoS = quality-of-service， 顾名思义，服务的质量。通常我们设计系统的时候不能完全排除故障或保证说没有故障，而应该设计有完善的异常处理机制。在出现错误的时候知道在哪里出现什么样子的错误，原因是什么，怎么去恢复或者处理才是真正应该去做的。在接收消息出现故障的时候我们可以通过RabbitMQ重发机制来处理。重发就有重发次数的限制，有些时候你不可能不限次数的重发，这取决于消息的大小，重要程度和处理方式。
甚至QoS是在接收端设置的。发 ...
rabbitmq-BasicReject
- 博客分类：
- rabbitmq
转自：http://www.cnblogs.com/haoxinyue/archive/2012/10/01/2709644.html
拒收，是接收端在收到消息的时候响应给RabbitMQ服务的一种命令，告诉服务器不应该由我处理，或者拒绝处理，扔掉。接收端在发送reject命令的时候可以选择是否要重新放回queue中。如果没有其他接收者监控这个queue的话，要注意一直无限循环发送的危险。
BasicDeliverEventArgs ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
channel.BasicReject(ea ...
rabbitmq-rpc
- 博客分类：
- rabbitmq
转自：http://backend.blog.163.com/blog/static/2022941262014315104836716/
在发送消息的时候也能够带上一些属性，以支持类似rpc的功能。在rabbitmq文档例子里，实现rpc功能实际上就是client发送带属性的消息，属性中包含回调tmp_queue名和用于标示该消息的correlationId。server端收到消息后从属性中取得tmp_queue，将处理的结果放在该queue中,并将拿到的correlationId作为结果消息的属性一并发送。client端有个while循环一直阻塞并获取tmp_queue消息，直到拿到响应 ...
转自：http://backend.blog.163.com/blog/static/2022941262014315104836716/
持久化消息，但是并不能完全保证消息不回丢失（不会每次接收到消息都fsync(2)），要保证消息不丢失，可以采用该方法
//开启事务
channel.txSelect();
//发送内容
channel.basicPublish("topic", "name", null, message.getBytes());
...
//提交事务
channel.txCommit();
//使用conf ...
rabbitmq-connection
- 博客分类：
- rabbitmq
一、ConnectionFactory
ConnectionFactory factory = new ConnectionFactory();
开启一个连接，默认localhost和默认端口
factory.newConnection(addressAry);
二、newConnection
完整的方法签名：
public Connection newConnection(ExecutorService executor, Address[] add ...
murmurhash
- 博客分类：
- 架构
转自:http://www.trueeyu.com/?p=1325
MurmurHash是一种非加密型哈希函数，由Austin Appleby在2008年发明，并且有多个变种。 特点：对于规律性较强的key，MurmurHash的随机分布特性表现更良好。
MurmurHash1是第一个版本，速度比Bob Jenkins'的lookup3，但不是非常robust. MurmurHash2速度更快并且robust，被应用于Google,Yahoo,Microsoft的很多公司的代码中 MurmurHash3是最新的版本，开发这个版本的原因是因为第二版有一些小缺 ...
Mycat-启动分析
- 博客分类：
- 中间件
mycat版本：1.4.1-DEV
mycat启动类：org.opencloudb.MycatStartup
mycat在linux启动时，采用java server wrapper进行包装，所以mycat启动配置jdk时，其实配置的是wrapper。
MYCAT_HOME
org.opencloudb.config.model.SystemConfig mycat系统基础配置项。
mycat启动时，首先会检查MYCAT_HOME是否设置。如果没有设置则读取正在运行程序的目录作为MYCAT_HOME.
MycatServer
org.opencloudb.M ...
有时候dtd文件由于网络原因找不到，但是有些dtd会存在与jar包中。可解压然后导入eclipse中。
1、window-preference-xml-xml catalog-user specified entries窗口中，选择add按钮。
2、在对话框中选择Location：
Location: F:\soft\programmingSoft\Framework\Ibatis\sql-map-config-2.dtd Key Type: URI KEY: http://ibatis.apache.org/dtd/sql-map-con ...
一种简单的方法：在eclipse的server视图中，双击打开设置视图。在视图左边timeouts-start属性将45修改为更大值。
oracle-type
- 博客分类：
- 数据库
一、as table of
例子1：
CREATE OR REPLACE TYPE "TYPE_NAME" as table of varchar2(25); --定义
declare
t_list type_name;
begin
select distinct (rs.id) bulk collect
into t_list
from t_cust_customers rs;
FOR cust_record IN (select vtable.column_value custid
...