- 浏览: 1030590 次
- 性别:
- 来自: 杭州
-
文章分类
- 全部博客 (826)
- 硬件 (8)
- 软件 (24)
- 软件工程 (34)
- JAVA (229)
- C/C++/C# (77)
- JavaScript (8)
- PHP (1)
- Ruby (3)
- MySQL (14)
- 数据库 (19)
- 心情记事 (12)
- 团队管理 (19)
- Hadoop (1)
- spring (22)
- mybatis(ibatis) (7)
- tomcat (16)
- velocity (0)
- 系统架构 (6)
- JMX (8)
- proxool (1)
- 开发工具 (16)
- python (10)
- JVM (27)
- servlet (5)
- JMS (26)
- ant (2)
- 设计模式 (5)
- 智力题 (2)
- 面试题收集 (1)
- 孙子兵法 (16)
- 测试 (1)
- 数据结构 (7)
- 算法 (22)
- Android (11)
- 汽车驾驶 (1)
- lucene (1)
- memcache (12)
- 技术架构 (7)
- OTP-Erlang (7)
- memcached (17)
- redis (20)
- 浏览器插件 (3)
- sqlite (3)
- Heritrix (9)
- Java线程 (1)
- scala (0)
- Mina (6)
- 汇编 (2)
- Netty (15)
- libevent (0)
- CentOS (12)
- mongod (5)
- mac os (0)
最新评论
-
kingasdfg:
你这里面存在一个错误添加多个任务 应该是这样的 /** * ...
Quartz的任务的临时启动和暂停和恢复【转】 -
kyzeng:
纠正一个错误,long型对应的符号是J,不是L。
Jni中C++和Java的参数传递 -
zhaohaolin:
抱歉,兄弟,只是留下作记录,方便学习,如果觉得资料不好,可以到 ...
netty的个人使用心得【转】 -
cccoooccooco:
谢谢!自己一直以为虚机得使用网线才可以与主机连接呢。。
主机网卡无网线连接与虚拟机通信 -
yuqilin001:
要转别人的东西,请转清楚点嘛,少了这么多类,误人子弟
netty的个人使用心得【转】
Hello ActiveMQ!
下面是ActiveMQ5.2的一个最简单例子!
环境还是apache-activemq-5.2.0-bin.zip,需要注意的是,开发时候,要将apache-activemq-
5.2.0-bin.zip解压缩后里面的activemq-all-5.2.0.jar包加入到classpath下面,这个包包含了所有jms接口
api的实现。
import
org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的生产者(发送者)
*
* @author leizhimin 2009-8-12 11:41:20
*/
public class JmsSender {
public static void main(String[] args) throws JMSException {
// ConnectionFactory :连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客户端到JMS Provider 的连接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session: 一个发送或接收消息的线程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination :消息的目的地;消息发送给谁.
// 获取session注意参数值my-queue是Query的名字
Destination destination = session.createQueue("my-queue" );
// MessageProducer:消息生产者
MessageProducer producer = session.createProducer(destination);
//设置不持久化
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//发送一条消息
sendMsg(session, producer);
session.commit();
connection.close();
}
/**
* 在指定的会话上,通过指定的消息生产者发出一条消息
*
* @param session 消息会话
* @param producer 消息生产者
*/
public static void sendMsg(Session session, MessageProducer producer) throws JMSException {
//创建一条文本消息
TextMessage message = session.createTextMessage("Hello ActiveMQ!" );
//通过消息生产者发出消息
producer.send(message);
System.out.println("");
}
}
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的生产者(发送者)
*
* @author leizhimin 2009-8-12 11:41:20
*/
public class JmsSender {
public static void main(String[] args) throws JMSException {
// ConnectionFactory :连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客户端到JMS Provider 的连接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session: 一个发送或接收消息的线程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination :消息的目的地;消息发送给谁.
// 获取session注意参数值my-queue是Query的名字
Destination destination = session.createQueue("my-queue" );
// MessageProducer:消息生产者
MessageProducer producer = session.createProducer(destination);
//设置不持久化
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//发送一条消息
sendMsg(session, producer);
session.commit();
connection.close();
}
/**
* 在指定的会话上,通过指定的消息生产者发出一条消息
*
* @param session 消息会话
* @param producer 消息生产者
*/
public static void sendMsg(Session session, MessageProducer producer) throws JMSException {
//创建一条文本消息
TextMessage message = session.createTextMessage("Hello ActiveMQ!" );
//通过消息生产者发出消息
producer.send(message);
System.out.println("");
}
}
import
org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的消费者(接受者)
*
* @author leizhimin 2009-8-12 11:41:33
*/
public class JmsReceiver {
public static void main(String[] args) throws JMSException {
// ConnectionFactory :连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客户端到JMS Provider 的连接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session: 一个发送或接收消息的线程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination :消息的目的地;消息发送给谁.
// 获取session注意参数值xingbo.xu-queue是一个服务器的queue,须在在ActiveMq的console配置
Destination destination = session.createQueue("my-queue" );
// 消费者,消息接收者
MessageConsumer consumer = session.createConsumer(destination);
while (true ) {
TextMessage message = (TextMessage) consumer.receive(1000);
if (null != message)
System.out.println("收到消息:" + message.getText());
else
break ;
}
session.close();
connection.close();
}
}
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
/**
* 消息的消费者(接受者)
*
* @author leizhimin 2009-8-12 11:41:33
*/
public class JmsReceiver {
public static void main(String[] args) throws JMSException {
// ConnectionFactory :连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://192.168.14.117:61616");
//JMS 客户端到JMS Provider 的连接
Connection connection = connectionFactory.createConnection();
connection.start();
// Session: 一个发送或接收消息的线程
Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
// Destination :消息的目的地;消息发送给谁.
// 获取session注意参数值xingbo.xu-queue是一个服务器的queue,须在在ActiveMq的console配置
Destination destination = session.createQueue("my-queue" );
// 消费者,消息接收者
MessageConsumer consumer = session.createConsumer(destination);
while (true ) {
TextMessage message = (TextMessage) consumer.receive(1000);
if (null != message)
System.out.println("收到消息:" + message.getText());
else
break ;
}
session.close();
connection.close();
}
}
启动ActiveMQ,然后开始执行:
先运行发送者,连续运行了三次,最后一次控制台输出:
Process finished with exit code 0
后运行接受者,输出结果:
收到消息Hello ActiveMQ!
收到消息Hello ActiveMQ!
收到消息Hello ActiveMQ!
Process finished with exit code 0
收到消息Hello ActiveMQ!
收到消息Hello ActiveMQ!
Process finished with exit code 0
注意:
其中的端口61616是ActiveMQ默认的配置,在activemq.xml中,
<!-- The transport connectors ActiveMQ will listen to
-->
< transportConnectors >
< transportConnector name ="openwire" uri ="tcp://localhost:61616" discoveryUri ="multicast://default" />
< transportConnector name ="ssl" uri ="ssl://localhost:61617" />
< transportConnector name ="stomp" uri ="stomp://localhost:61613" />
< transportConnector name ="xmpp" uri ="xmpp://localhost:61222" />
</ transportConnectors >
< transportConnectors >
< transportConnector name ="openwire" uri ="tcp://localhost:61616" discoveryUri ="multicast://default" />
< transportConnector name ="ssl" uri ="ssl://localhost:61617" />
< transportConnector name ="stomp" uri ="stomp://localhost:61613" />
< transportConnector name ="xmpp" uri ="xmpp://localhost:61222" />
</ transportConnectors >
,建议不要改动,都用这个端口多好,就像ftp都用21端口,也没错。
这是官方的HelloWorld例子,不过看着不顺眼:
----------------------
推荐一些文章:
发表评论
-
Advanced Message Queuing Protocol ( 3 ) 逻辑模型
2011-05-07 22:04 1222Sessions 建立在不同容器中的两个节点的链接必 ... -
Advanced Message Queuing Protocol ( 2 ) 逻辑模型
2011-05-07 22:04 1039Nodes and Links 一个AMQP的网络包 ... -
Advanced Message Queuing Protocol ( 1 ) 概述
2011-05-07 22:03 1305The Advanced Message Queuing ... -
Apache Qpid (1) -- build
2011-05-07 22:02 2014http://qpid.apache.org/index.h ... -
ActiveMQ技术预研报告【转】
2011-04-22 14:44 1975ActiveMQ技术预研报告 研究部朱懋柱 1.文 ... -
ActiveMQ与MSMQ的异同【转】
2011-04-22 14:14 1995.NET下发送和接收ActiveMQ A:下载Act ... -
ActiveMQ在C#中的应用
2011-04-21 16:18 1274ActiveMQ 是个好东东,不必多说。ActiveM ... -
ActiveMQ实战之 Queue点对点消息【转】
2011-04-18 23:15 1274对于此类消息,其实就是指使用JMS中的发P2P(点对点)消息模 ... -
ActiveMQ实战之 Topic发布订阅消息【转】
2011-04-18 23:14 1250对于此类消息,其实就是指使用JMS中的发布订阅消息模型的消息, ... -
ActiveMQ实战(4):JMS的安全性【转】
2011-04-18 22:52 1289对于JMS服务的安全控制,ActiveMQ提供两种方式:简单授 ... -
ActiveMQ实战(3):Web控制台的安全性【转】
2011-04-18 22:52 1404安装好ActiveMQ后,其默认没有任何安全控制,任何人都可以 ... -
ActiveMQ实战(2):测试其是否正常工作【转】
2011-04-18 22:51 1278既然ActiveMQ安装好了并启动成功,接下来我们就编写一个测 ... -
ActiveMQ实战(1):安装与运行【转】
2011-04-18 22:45 1860ActiveMQ的项目主页:http://activemq.a ... -
[转] JMS开源比较
2011-03-30 23:46 1254Java开源JMS消息中间件 ... -
activemq5.2发送和接收BlobMessage简单实例
2011-03-29 23:45 1246package com.work.activemq ... -
ActiveMQ学习笔记----ActiveMQ和JBossMQ性能对比测试代码
2011-03-29 23:44 1305本文描述了对ActiveMQ进行性能测试的代码。性能测试用 ... -
ActiveMQ 实例
2011-03-29 23:21 11312009-06-24 ProducerTool.java ... -
activemq持久化配置,设置为主从模式(带复制的主从模式,应用mysql数据库)
2011-03-29 09:12 1898activemq持久化配置,设置为主从模式(带复制的主从模 ... -
ActiveMQ持久化消息的三种方式
2011-03-29 09:11 14351:前言 这一段给公司开发消息总线有机会研究A ... -
什么是JMS(Java消息服务)
2011-03-28 19:28 970在不同系统之间交换信息的一大障碍是如何在精确交换和格式化数据方 ...
相关推荐
单片机开发教程代码涉及多个方面,包括硬件连接、软件编程、调试与优化等。以下是一个基于51单片机的简单教程代码示例,以及相关的开发步骤和解释。 ### 一、硬件连接 在进行单片机开发之前,首先需要正确连接硬件。以51单片机为例,通常需要将单片机的各个引脚与外围设备(如LED灯、按键、传感器等)进行连接。以下是一个简单的硬件连接示例: 1. 将单片机的P1.0引脚与LED灯的正极相连,LED灯的负极接地。 2. 将单片机的P3.2、P3.3、P3.4、P3.5引脚分别与四个按键的一端相连,按键的另一端接地。 ### 二、软件编程 在进行软件编程时,需要选择合适的编程语言(如C语言)和编译环境(如Keil C51)。以下是一个简单的51单片机程序示例,用于控制LED灯的亮灭和按键的扫描: ```c #include <reg51.h> sbit LED = P1^0; // 定义LED灯连接的引脚 void delay(unsigned int time) { unsigned int i, j; for (i = 0; i < time; i++) {
《顶刊复现》(复现程度90%),Reinforcement Learning-Based Fixed-Time Trajectory Tracking Control for Uncertain Robotic Manipulators With Input Saturation,自适应强化学习机械臂控制,代码框架方便易懂,适用于所有控制研究爱好者。 ,《深度强化学习复现:自适应控制框架下的机械臂轨迹跟踪控制研究》,强化学习机械臂控制的自适应轨迹跟踪:高复现度与易懂代码框架研究报告,核心关键词:顶刊复现; 强化学习; 固定时间轨迹跟踪控制; 不确定机械臂; 输入饱和; 自适应控制; 代码框架; 控制研究爱好者。,《基于强化学习的机械臂固定时间轨迹跟踪控制:复现程度高达90%》
通过分析企业对于飘香水果购物网站的需求,创建了一个计算机管理飘香水果购物网站的方案。文章介绍了飘香水果购物网站的系统分析部分,包括可行性分析等,系统设计部分主要介绍了系统功能设计和数据库设计。 本飘香水果购物网站管理员功能有,个人中心管理,用户管理,会员管理,会员卡管理,开通会员记录管理,积分管理,水果管理,购买水果订单管理,积分兑换管理,积分兑换记录管理,加积分记录管理,减积分记录管理。用户可以注册登录,在首页开通会员卡,查看水果,购买水果,查看水果信息,以及个人中心修改个人资料,在自己的后台查看自己的购买记录等。因而具有一定的实用性。 本站是一个B/S模式系统,采用Spring Boot框架作为开发技术,MYSQL数据库设计开发,充分保证系统的稳定性。系统具有界面清晰、操作简单,功能齐全的特点,使得飘香水果购物网站管理工作系统化、规范化。 关键词:飘香水果购物网站;Spring Boot框架;MYSQL数据库
地区:全国都有。时间:近半年的都有,之前的需要查数据库。数据来源:百度慧眼 数据形式:含坐标的CSV点数据;SHP数据;TIFF栅格数据;多种数据形式可选。任意精度,10,30,50m均可。 价格:市为单位,每天有24个时间点。数据格式不同价格不同。 用途:城市/街道活力,人口统计,选址分析,商圈分析,活力分析等等。
1998-2022年各地级市第三产业占GDP比重/地级市第三产业占比数据(市辖区) 1、时间:1998-2022年 2、指标:地级市第三产业占GDP比重/地级市第三产业占比 3、来源:城市统计年鉴 4、范围:299个地级市 5、缺失情况:缺失情况与年鉴一致,表内附有年鉴第三产业占比原始数据,以2022年地级市名单进行统计整理,为市辖区数据
网站精美前端设计,使用jQuery+CSS开发,源码适用于参考学习使用。希望对你学习和开发有所帮助
本项目是基于SSM框架开发的固定设备资产管理系统,旨在实现企业资产全生命周期数字化管理。系统采用B/S架构,前端通过JSP、Vue等技术实现交互界面,后端以Spring、SpringMVC和MyBatis为核心框架构建业务逻辑层,数据库采用MySQL存储资产信息16。
内容概要:本文基于对称折叠、卷式折叠和环向折叠三种气囊折叠方式,通过虚拟试验平台,采用气囊试验、碰块试验和转向盘试验,深入分析了各种气囊折叠方式在两个阶段内的气压特性及其对乘员保护性能的影响。结果发现气囊的展开过程中存在两阶段特征(初期展开阶段为0~20ms,完全展开工作阶段为20~100ms),不同折叠层数会导致不同的展开阻力,影响展开时间和内部压力;特别是环向折叠方式因其展开阻力较小,能够更快且平稳地提供保护力,并且能在早期阶段对靠近模块的离位乘客施加较小的力量,适合于大体型正常坐姿的乘客保护;卷式折叠适用于小型体态乘客;而对称折叠则是标准体型乘客的最佳选择。 适合人群:从事车辆被动安全性研究的技术人员、安全系统工程师、交通安全领域的研究人员,以及对高级辅助驾驶技术和安全性能感兴趣的学术界人士和专业学生。 使用场景及目标:该研究表明,通过对不同气囊折叠方法的研究,能够指导实际产品优化设计,提升乘客保护性能,同时也有助于制定科学合理的法规和规范,确保乘客在突发交通事故条件下能够得到最大程度的安全保障。 其他说明:本研究由国家自然科学基金资助,并借助有限元程序LS-DYNA进行数值模拟
MATLAB gui界面设计 MATLAB图像处理 gui界面开发 傅立叶变,灰度图,二值化,直方图均衡,高通滤波器,低通滤波器,巴特沃斯滤波器,噪声处理,边缘检测 ,MATLAB图像处理与GUI界面开发:实现傅立叶变换及高级滤波算法应用与解析,MATLAB GUI界面开发及应用实践:图像处理、滤波与边缘检测的完整解决方案,MATLAB GUI界面设计; MATLAB图像处理; gui界面开发; 图像处理技术; 傅立叶变换; 图像灰度化; 二值化处理; 直方图均衡化; 滤波器(高通/低通/巴特沃斯); 噪声处理; 边缘检测。,MATLAB图像处理与GUI界面开发实践:高级图像处理技术与应用
资源的描述略
矢量边界,行政区域边界,精确到乡镇街道,可直接导入arcgis使用
网站精美前端设计,使用jQuery+CSS开发,源码适用于参考学习使用。希望对你学习和开发有所帮助
Kotlin语言基础入门:Kotlin简介 在2019年Google I/O大会上,Google 宣布今后将优先采用 Kotlin 进行 Android 开发。 一,简介 Kotlin 是一种富有表现力且简洁的编程语言,不仅可以减少常见代码错误,还可以轻松集成到现有应用中。 Google 列举的 Kotlin 的优势: • 富有表现力且简洁:可以使用更少的代码实现更多的功能。表达自己的想法,少编写样板代码。 • 更安全的代码:Kotlin 有许多语言功能,可帮助你避免null指针异常等常见编程错误。 • 可互操作:可以在 Kotlin 代码中调用 Java 代码,或者在 Java 代码中调用 Kotlin 代码。Kotlin 可完全与 Java 编程语言互操作。 • 结构化并发:Kotlin 协程让异步代码像阻塞代码一样易于使用。协程可大幅简化后台任务管理。 更重要的是,Jetpack Compose 仅支持 Kotlin,而不再支持 Java。 Google 提到多平台项目可使用 Kotlin 来开发。
本项目是基于JSP与JavaEE技术栈开发的传统文化学习系统,旨在通过数字化手段实现中华优秀传统文化的传承与创新。系统采用经典的MVC架构模式,后端通过Servlet处理业务逻辑,JSP动态生成交互页面,结合MySQL数据库存储用户信息、课程内容及学习记录等核心数据3。主要功能模块涵盖用户注册登录、课程分类学习(如诗词鉴赏、书法入门)、多媒体资源管理(含视频讲解与电子书库)、在线测试评估及社区互动交流等,支持管理员对课程体系和用户权限的集中管理16。开发过程中整合了文件上传、缓存优化等实用技术,前端界面采用响应式设计,适配PC端与移动端浏览。该项目不仅为传统文化爱好者提供系统化学习路径,也为教育工作者搭建了资源共享与教学管理平台,助力文化自信的培育37。毕设项目源码常年开发定制更新,希望对需要的同学有帮助。
资源的描述略
冷链物流路径优化与调度模型研究 - 遗传算法求解及应用
1998-2022年各地级市第二产业占GDP比重/地级市第二产业占比数据(市辖区) 1、时间:1998-2022年 2、指标:地级市第二产业占GDP比重/地级市第二产业占比 3、来源:城市统计NJ 4、范围:299个地级市 5、缺失情况:缺失情况与年鉴一致,表内附有年鉴第二产业占比原始数据,以2022年地级市名单进行统计整理,为市辖区数据
网站精美前端设计,使用jQuery+CSS开发,源码适用于参考学习使用。希望对你学习和开发有所帮助
复现Energy一区top之融合多策略的改进蜣螂优化算法,提供参考文献,改进如下: 1、Fuch和逆向学习策略混合 2、自适应步长 3、凸透镜成像策略 4、随机差分变异 ,复现Energy一区顶尖融合多策略改进蜣螂优化算法研究,包含Fuch与逆向学习混合策略等四大改进点参考文献,复现Energy一区顶尖融合多策略改进蜣螂优化算法研究,包含Fuch与逆向学习混合策略等四大改进点参考文献,一区top_Energy融合;多策略改进;蜣螂优化算法;Fuch逆向学习策略混合;自适应步长;凸透镜成像策略;随机差分变异;参考文献,基于改进多策略的蜣螂优化算法在Energy领域的应用与优化分析
本项目是基于SSM框架开发的少儿编程教育网站,旨在为儿童提供互动性强、资源丰富的在线编程学习平台。系统采用B/S架构,前端使用JSP技术实现动态页面展示,后端通过Spring、SpringMVC和MyBatis框架整合业务逻辑与数据交互,数据库采用MySQL存储用户信息、课程数据及学习记录134。