1.1 java消息服务:不同系统之间的信息交换，是我们开(13)

//判断消息的类型

instanceof用于判断一个变量是否某个对象的实例，如var a=new array()。 } //插入一条数据 int insertdata(database* db,student stu) { //插入前先判断空间是否已满 if(db->count == db->size)//如果满了，要先扩展空间 { db->size *= 22。

String text = null;

try {

text = ((TextMessage) message).getText();

} catch (JMSException e) {

e.printStackTrace();

}

system.out.println("java.home : "+system.getproperty("java.home"))。 system.out.println("user.name : "+system.getproperty("user.name"))。 system.out.println("耗时：" + (system.currenttimemillis() - begin))。system.out.println("原内容：\n" + sb.tostring())。

}

}

});

} catch (JMSException e) {

e.printStackTrace();

} finally {

/*try {

//关闭连接释放资源

if (null != messageConsumer) {

messageConsumer.close();

}

if (null != session) {

session.close();

}

if (null != connection) {

connection.close();

}

} catch (JMSException e) {

e.printStackTrace();

}*/

}

}

}

三.ActiveMQ的集成使用:

3.1ActiveMQ与Spring集成(以下是一个简单的上手Demo):

鉴于发送端与接收端pom文件依赖相同,所以只写一份,依赖如下:

[html]view plain copy

<!--spring-jms依赖-->

<dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-jms</artifactId>

<version>4.3.13.RELEASE</version>

</dependency>

<!--activemq的jar依赖-->

<dependency>

at org.apache.storm.shade.org.yaml.snakeyaml.parser.parserimpl.peekevent(parserimpl.java:158) 。 at org.apache.storm.shade.org.yaml.snakeyaml.composer.composer.composesequencenode(composer.java:203) 。

>魔法使和战士，通过议案“くの一を作りたいでござる”<，通过议案“怪しいジジイを作りたい”<：< >：各击破一次（没击破前不能捕获），通过议案“夕日が似合う男を作りたい”<，通过议案“罪人を作りたい”< 魔物使い：アクターレ篇通关<，通过议案“グラマー美_女 を作りたい”<：剑与仗熟练度均在3以上，通过议案“東洋の剣士を作りたい”<，通过议案“タフガイを作りたい”< >，通过议案“忍者を作りたいでござる”。>,>,>,>,>,加点方案<,<,<,<,<,职业：鬼剑士>,阿修罗>,大暗黑天>,天帝等级：85sp：全部10770已用10760剩余10tp：。

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-94236-13.html