文档章节

Mq测试

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

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();
  }
  }
}

© 著作权归作者所有

共有 人打赏支持
上一篇: 数据迁移
下一篇: Redis测试
东门非树
粉丝 0
博文 11
码字总数 4040
作品 0
南京
私信 提问
Kafka压力测试(写入MQ消息压测和消费MQ消息压测)

1.测试目的 本次性能测试在正式环境下单台服务器上Kafka处理MQ消息能力进行压力测试。测试包括对Kafka写入MQ消息和消费MQ消息进行压力测试,根据10w、100w和1000w级别的消息处理结果,评估K...

数据架构师
2018/11/06
0
0
消息队列的简单使用

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

可达鸭眉头一皱
2018/03/02
0
0
IBM WebSphere MQ 系列(三)配置和使用WebSphere MQ

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

yzbty23
2015/12/01
174
0
配置IBM WEBSPHERE MQ触发器

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

yzbty23
2015/12/01
86
0
黄登峰/spring-amq

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

黄登峰
2016/11/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

如何在 Linux 系统查询机器最近重启时间

在你的 Linux 或类 UNIX 系统中,你是如何查询系统上次重新启动的日期和时间?怎样显示系统关机的日期和时间? last 命令不仅可以按照时间从近到远的顺序列出该会话的特定用户、终端和主机名...

来来来来来
40分钟前
0
0
Redis协议是什么样的

前言 我们用过很多redis的客户端,有没有相过自己撸一个redis客户端? 其实很简单,基于socket,监听6379端口,解析数据就可以了。 redis协议 解析数据的过程主要依赖于redis的协议了。 我们...

春哥大魔王的博客
57分钟前
2
0
乱入Linux界的我是如何学习的

欢迎来到建哥学Linux,咳!咳!咳!开个玩笑哈,我是一个IT男,IT界的入门选手,正在学习Linux。 在之前,一直想进军IT界,学习IT技术,但是苦于没有人指导,也不知道学什么,最开始我自己在...

linuxCool
今天
1
0
携程Apollo统一配置中心的搭建和使用(java)

一.Apollo配置中心介绍 1、What is Apollo 1.1 Apollo简介 Apollo(阿波罗)是携程框架部门研发的开源配置管理中心,能够集中化管理应用不同环境、不同集群的配置,配置修改后能够实时推送到...

morpheusWB
今天
1
0
远程获得的有趣的linux命令

使用这些工具从远程了解天气、阅读资料等。 我们即将结束为期 24 天的 Linux 命令行玩具日历。希望你有一直在看,如果没有,请回到开始,从头看过来。你会发现 Linux 终端有很多游戏、消遣和...

Linux就该这么学
今天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部