文档章节

Mq测试

东门非树
 东门非树
发布于 2014/11/13 10:38
字数 89
阅读 45
收藏 1
点赞 0
评论 0

public class MqSubscriberTest extends Thread {
 private Semaphore semaphore = new Semaphore(0);
 ScheduledExecutorService service = Executors.newScheduledThreadPool(100);
 MessageMqSubscriberRunnable listeningTask  = null;
 public static void main(String[] args) {

  try {
   MqSubscriberTest test = new MqSubscriberTest();
   MessageMqSubscriberRunnable listeningTask = new MessageMqSubscriberRunnable();
   test.service.schedule(listeningTask, 1, TimeUnit.SECONDS);
   test.start();
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } //启动服务器  
  
 }

 public MqSubscriberTest() throws IOException {
  //rverSocket = new ServerSocket(port);
  System.out.println("ComServer Start");
 }
 public void run(){
  try {
   this.semaphore.acquire();
  } catch (InterruptedException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  }
}

© 著作权归作者所有

共有 人打赏支持
东门非树
粉丝 0
博文 10
码字总数 4040
作品 0
南京
IBM WebSphere MQ 系列(三)配置和使用WebSphere MQ

配置和使用WebSphere MQ A.设置环境变量 在shell中执行MQ的控制命令: ctrmqm strmqm 若识别这些命令,则说明PATH环境变量已配置好了; 若提示找不到命令,则说明需配置Linux环境变量,指定M...

yzbty23 ⋅ 2015/12/01 ⋅ 0

消息队列的简单使用

/// <summary> /// 创建消息队列 /// </summary> /// <param name="name">消息队列名称</param> /// <returns></returns> public void CreateNewQueue(string name) { if (!System.Messagin......

可达鸭眉头一皱 ⋅ 03/02 ⋅ 0

连接IBM websphere MQ原因码报2035的错误解决办法 (MQ Security)

在一台机器上安装有MQ Server;在另外一台机器上,安装WAS,打算通过管理控制台中的资源--》JMS--》队列连接工厂,建立队列连接工厂到MQServer。 但在新建队列连接工厂,测试连接的时候出现2...

cyper ⋅ 2014/02/13 ⋅ 0

配置IBM WEBSPHERE MQ触发器

配置IBM WEBSPHERE MQ触发器 2007-11-15 创建 一般设置MQ触发器的目的有两种, 一是自动启动发送端通道, 二是监视队列消息, 一旦发现新的消息, 则利用触发器启动相应的处理进程 如果是利用触发...

yzbty23 ⋅ 2015/12/01 ⋅ 0

黄登峰/spring-amq

Spring-mq项目简介 spring 对active mq的封装 简化操作 使用Maven对项目进行模块化管理,提高项目的易开发性、扩展性。 系统包括对queue 和 topic 的的操作模拟 利用spring 提供的jmstempla...

黄登峰 ⋅ 2016/11/14 ⋅ 0

基于giiwa 框架的 RabbitMQ 模块--grabbitmq

基于giiwa 框架的 RabbitMQ 模块 关于giiwa, 请参阅 http://giiwa.org 提供 RabbitMQ 的基本配置管理,并向其他模块提供MQ API,以实现分布式处理和简化其他模块的开发。 功能介绍 MQ消息队...

joe-j ⋅ 2016/09/26 ⋅ 1

2016.2.16 ActiveMQ集群负载均衡、安装、配置

一. MQ介绍 二. MQ适用场景 三. 以ActiveMQ为例,集群安装、配置、负载均衡 我们使用ZooKeeper和LevelDB搭建ActiveMQ集群,使用ZooKeeper(集群)注册所有的ActiveMQ Broker。只有其中的一个...

lbnan ⋅ 2016/02/16 ⋅ 0

xsgong/docker-wmq

#docker-wmq 前几天已经把WebSphere MQ 7.5安装在CentOS 7上了,今天经理又要求在另外一个云的另一台服务器上准备一个新环境,看起来安装MQ的需求还是很旺盛的。因此笔者决定制作一个Docker镜...

xsgong ⋅ 2016/04/29 ⋅ 0

rabbitMQ的下载安装

下载安装 Ubuntu版本: >>echo'deb http://www.rabbitmq.com/debian/ testing main'|sudotee /etc/apt/sources.list.d/rabbitmq.list >>wget -O- https://www.rabbitmq.com/rabbitmq-releas......

眼君 ⋅ 2017/12/08 ⋅ 0

IBM MQ 连接报错

一台 Win 服务器, 在 1414 端口上有 IBM 的 MQ 在本地的 Win 系统上 telnet 测试 端口是通的 在本地的 linux 系统上,telnet 测试 端口不通,nmap 扫描下,也没有发现 1414 端口, 但用 nc 命令...

溱 ⋅ 2017/04/15 ⋅ 1

没有更多内容

加载失败,请刷新页面

加载更多

下一页

JavaScript零基础入门——(十)JavaScript的DOM基础

JavaScript零基础入门——(十)JavaScript的DOM基础 欢迎大家回到我们的JavaScript零基础入门,上一节课,我们了解了JavaScript中的函数,这一节课,我们来了解一下JavaScript的DOM。 第一节...

JandenMa ⋅ 31分钟前 ⋅ 0

Spring mvc DispatchServlet 实现原理

在Spring中, ContextLoaderListener只是辅助类,在web 容器启动的时候查找并创建WebApplicationContext对象,通过该对象进行加载spring的配置文件。而真正的逻辑实现其实是在DispatcherSer...

轨迹_ ⋅ 42分钟前 ⋅ 0

Weex起步

本教程假设你已经在你的本地环境安装了node 其实weex起步教程在 https://github.com/lilugirl/incubator-weex 项目说明文件中都已经有了,但为了有些同学看到英文秒变文盲,所以这里我重新写...

lilugirl ⋅ 50分钟前 ⋅ 0

Jenkins实践1 之安装

1 下载 http://mirrors.jenkins.io/war/latest/jenkins.war 2 启动 java -jar jenkins.war 前提:安装jdk并配置环境变量 启动结果节选: ************************************************......

晨猫 ⋅ 57分钟前 ⋅ 0

组合数学 1-2000 中,能被6或10整除的数的个数

1--2000 中,能被6或10整除的数的个数 利用集合的性质 能被6整除的个数 2000/6 = 333 能被10整除的个数 2000/10 = 200 能被6和10整除的个数 2000/30 = 66 能被6或10整除的个数 333+200-66 =...

阿豪boy ⋅ 今天 ⋅ 0

一篇文章学懂Shell脚本

Shell脚本,就是利用Shell的命令解释的功能,对一个纯文本的文件进行解析,然后执行这些功能,也可以说Shell脚本就是一系列命令的集合。 Shell可以直接使用在win/Unix/Linux上面,并且可以调用...

Jake_xun ⋅ 今天 ⋅ 0

大数据工程师需要精通算法吗,要达到一个什么程度呢?

机器学习是人工智能的一个重要分支,而机器学习下最重要的就是算法,本文讲述归纳了入门级的几个机器学习算法,加大数据学习群:716581014一起加入AI技术大本营。 1、监督学习算法 这个算法由...

董黎明 ⋅ 今天 ⋅ 0

Kylin 对维度表的的要求

1.要具有数据一致性,主键值必须是唯一的;Kylin 会进行检查,如果有两行的主键值相同则会报错。 2.维度表越小越好,因为 Kylin 会将维度表加载到内存中供查询;过大的表不适合作为维度表,默...

无精疯 ⋅ 今天 ⋅ 0

58到家数据库30条军规解读

军规适用场景:并发量大、数据量大的互联网业务 军规:介绍内容 解读:讲解原因,解读比军规更重要 一、基础规范 (1)必须使用InnoDB存储引擎 解读:支持事务、行级锁、并发性能更好、CPU及...

kim_o ⋅ 今天 ⋅ 0

代码注释中顺序更改 文件读写换行

`package ssh; import com.xxx.common.log.LogFactory; import com.xxx.common.log.LoggerUtil; import org.apache.commons.lang3.StringUtils; import java.io.*; public class DirErgodic ......

林伟琨 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部