文档章节

activeMQ的简单案例

蜀山下的鱼
 蜀山下的鱼
发布于 2015/04/29 00:38
字数 362
阅读 44
收藏 1

我的分享:activeMQ的资料

 

 

这里导入lib包后即可运行代码,具体的流程可以看资料:首先启动activeMQ,再运行send和receive程序!

 

package jms;

import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.log4j.PropertyConfigurator;

public class PTP_sends {
	/**
	 * @param args
	 */
	
	public PTP_sends(){
		
	}

    private Connection connection;
    private String subject = "TOOL.DEFAULT";


    public void send(String msg){
    	//创建connectionFaction

    	ActiveMQConnectionFactory connectionFactory =new ActiveMQConnectionFactory("tcp://localhost:61616");
    	try {
			//创建connection
    		connection=connectionFactory.createConnection();
			connection.start();
			//创建session,设置消息确认机制
			Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			//创建destination
			Destination destination=session.createQueue(subject);
			//创建producer
			MessageProducer producer=session.createProducer(destination);
			//设置JMS的持久性
			producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
			//JMS消息体
			TextMessage message = session.createTextMessage(msg);
			
			//发生消息message
			producer.send(message);
			System.out.println("消息已经发送。。。。");
			
			
			
			//关闭资源
			message.clearProperties();
			session.close();
			connection.stop();
			connection.close();
			System.out.println("关闭资源。。。。");
		} catch (JMSException e) {
			e.printStackTrace();
		}
    }
    
    public static void main(String[] args) {
		PropertyConfigurator.configure("c:\\log4j.properties");
		
		//代码启动activeMQ
//		BrokerService broker = new BrokerService();
//		try {
//			broker.addConnector("tcp://localhost:61616");
//			broker.start();
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
		
		PTP_sends ptpSends=new PTP_sends();
		ptpSends.send("this is JMS .....");
	}

}


 

package jms;

import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.log4j.PropertyConfigurator;

public class PTP_receive {

	/**
	 * @param args
	 */
	
    private Connection connection;
    private String subject = "TOOL.DEFAULT";
    
    
    
	 public void receive(){
	      	ActiveMQConnectionFactory connectionFactory =new ActiveMQConnectionFactory();
	    	try {
				//创建connection
	    		connection=connectionFactory.createConnection();
				connection.start();
				//创建session
				Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
				//创建destination
				Destination destination=session.createQueue(subject);
				MessageConsumer consumer=session.createConsumer(destination);
				System.out.println("同步接受消息:");
				Message message=consumer.receive();
				System.out.println("\n收到的message 是:"+((TextMessage)message).getText());
				
				
				//关闭资源
				message.clearProperties();
				consumer.close();
				session.close();
				connection.stop();
				connection.close();
				System.out.println("关闭资源。。。。");
	    	} catch (JMSException e) {
				e.printStackTrace();
			}
	    }
	    
	public static void main(String[] args) {
		PropertyConfigurator.configure("c:\\log4j.properties");
		PTP_receive receive=new PTP_receive();
		receive.receive();
	}

}

PS:很简陋,主要给自己笔记而已,不明白的可以联系我吧!

本文转载自:http://blog.csdn.net/caiwenfeng_for_23/article/details/8606538

蜀山下的鱼
粉丝 9
博文 405
码字总数 0
作品 0
广州
高级程序员
私信 提问
加载中

评论(0)

ActiveMQ安装配置和使用简例

本文作者:Zhang Phil 原文链接:http://blog.csdn.net/zhangphil/article/details/48173665 ActiveMQ安装配置和使用简例 ActiveMQ是一套JMS(Java Message Service)开源消息服务实现的组件...

开开心心过
2015/09/02
0
0
ActiveMQ集群方案(下)

版权声明:欢迎转载,但是看在我辛勤劳动的份上,请注明来源:http://blog.csdn.net/yinwenjie(未经允许严禁用于商业用途!) https://blog.csdn.net/yinwenjie/article/details/51205822 目...

yunlielai
2018/04/15
0
0
跟我学习dubbo-ActiveMQ的安装-单节点与使用(9)

ActiveMQ 的安装与使用(单节点) 1、 安装 JDK 并配置环境变量 JAVA_HOME=/usr/local/java/jdk1.7.0_72 2、 下载 Linux 版的 ActiveMQ(当前最新版 apache-activemq-5.11.1-bin.tar.gz) $ ...

HI曲奇饼干
2016/01/19
238
0
Linux环境下Apache ActiveMQ 基本安装

在linux上安装mq,并映射到外网。 1.Apache ActiveMQ安装基本条件请参考链接: 2.下载Apache ActiveMQ 3.解压安装 将下载好的apache-activemq-5.13.3-bin.tar解压至安装目录 命令:tar -zxvf...

zhuyuansj
2018/04/02
0
0
springmvc和activemq的整合使用

1、简介:ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今...

小不点丶
2017/05/24
0
0

没有更多内容

加载失败,请刷新页面

加载更多

如何创建spring-boot的web项目

第一步:新建一个maven项目 新建项目,选择maven 填写GroupId和ArtifactId 下一步默认即可,直接点击finish 创建完成后项目结构如下 第二步: 配置pom.xml 在pom.xml中添加如下代码: <p...

幻境fairy
28分钟前
46
0
「网易官方」极客战记(codecombat)攻略-地牢-Kithgard 斗殴-kithgard-brawl

每次你从一波波的敌人中存活下来,就会变得更难。但是你如果你输了,你必须要等一天后才能再次提交。 简介 这是一个无尽的挑战关卡,敌人会一波波地向你发起进攻,一次比一次强大,直到你坚持...

极客战记
31分钟前
68
0
基于数据回放功能开发的线性挂单流策略

前言 人们常说,交易是一门艺术,而艺术来源于灵感。所以今天想和大家分享一下,如何利用发明者量化数据回放功能,发掘自己的交易灵感。 交易的灵感和盘感 通常我们所说的灵感,是指人们在思...

发明者量化
35分钟前
40
0
技术答疑丨如何区分游戏短音乐与音效以及配音

在游戏的声音领域,一般游戏音乐、音效与配音,但是每个类别又有不同的细分,在我们奇亿音乐与游戏厂商的日常沟通中,发现这些问题一直困扰着大家,一起来看看吧。 1、如何区分游戏的音效与配...

奇亿音乐
36分钟前
66
0
如何在mac上录屏

新上手的苹果电脑,想要完成录屏操作还不知道从哪下手的小伙伴有福利了,小编今天分享如何在mac上录屏内容,需要的来一起了解吧~ 如何在mac上录屏 Aiseesoft Screen Recorder for Mac(录屏软...

麦克虾仔
48分钟前
48
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部