文档章节

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...

数据架构师
11/06
0
0
IBM WebSphere MQ 系列(三)配置和使用WebSphere MQ

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

yzbty23
2015/12/01
174
0
消息队列的简单使用

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

可达鸭眉头一皱
03/02
0
0
连接IBM websphere MQ原因码报2035的错误解决办法 (MQ Security)

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

cyper
2014/02/13
0
0
配置IBM WEBSPHERE MQ触发器

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

yzbty23
2015/12/01
86
0

没有更多内容

加载失败,请刷新页面

加载更多

用POLARDB构建客到智能餐饮系统实践

摘要: 在新零售成为大趋势的今天,餐饮行业也加入到这一浪潮之中。智能餐饮系统将帮助餐饮行业从多个维度提升自己的运营能力和收益,而打造智能餐饮系统SaaS化能力也成为了目前的一个热点。...

阿里云官方博客
23分钟前
0
0
aws S3 util demo

package com.example.demo;import com.amazonaws.AmazonClientException;import com.amazonaws.AmazonServiceException;import com.amazonaws.auth.BasicAWSCredentials;import co......

经常把天聊死的胖子
今天
4
0
linux下查看cpu、memo、io、swap性能数据脚本

直接贴脚本: 1、cpu #!/bin/bashCurrentDate=`date -d today '+%Y%m%d'`CurrentTime=`date -d today '+%Y%m%d%H%M'`mytext="$CurrentTime\t`top -b -n 1 | grep Cpu\(s\......

郑加威
今天
5
0
MySQL之——查询重复记录、删除重复记录方法大全

MySQL之——查询重复记录、删除重复记录方法大全

安小乐
今天
2
0
spring容器启动,停止,关闭事件监听-ApplicationEvent

ApplicationEvent ApplicationEvent相当于一个事件,所有自定义事件都需要继承这个抽象类。在Eclipse中Ctrl+Shift+H调用类的层次结构列表,可以看到如下 Application下抽象子类ApplicationCo...

tantexian
今天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部