语源科技BlogJava-初一七月

package阶段跳过test

初一七月 — Tue, 05 Nov 2013 09:21:00 GMT

1.命令行方式
跳过测试

1 mvn package -DskipTests

跳过编译和测试

1 mvn package -Dmaven.test.skip=true

2.pom.xml配置文件方式

1 <project>
2   []
3   <build>
4     <plugins>
5       <plugin>
6         <groupId>org.apache.maven.pluginsgroupId>
7         <artifactId>maven-surefire-pluginartifactId>
8         <version>2.4.2version>
9         <configuration>
10           <skipTests>trueskipTests>
11         configuration>
12       plugin>
13     plugins>
14   build>
15   []
16 project>
17

初一七月 2013-11-05 17:21 发表评论

MyEclipse 6.5安装maven插件

初一七月 — Tue, 05 Nov 2013 08:19:00 GMT

一、卸载原有maven插件

MyEclipse 6.5集成了Maven插件，不过有不少bug，用习惯了m2eclipse，不想在这上面浪费时间。要安装m2eclipse，需要先把自带的maven插件卸载掉，卸载步骤如下：
1.删除/eclipse/features/com.genuitec.myeclipse.maven_6.5.1.zmyeclipse650200806目录
2.进入plugins目录，删除以下目录及jar包

1 com.genuitec.myeclipse.maven_6.5.1.zmyeclipse650200806
2 org.maven.ide.components.archetype_common_2.0.0.20080331-1600
3 org.maven.ide.components.maven_embedder_2.1.0.20080410-2200
4 org.maven.ide.components.maven_model_edit_1.0.0.20080331-1600
5 org.maven.ide.components.maven_scm_1.0.0.20080410-2200
6 org.maven.ide.components.nexus_indexer_1.0.0.20080331-1600
7 org.maven.ide.components.qname_1.0.0.20080331-1600
8 com.genuitec.eclipse.maven_6.5.1.zmyeclipse650200806.jar
9 org.maven.ide.eclipse.central_0.9.1.zmyeclipse650200806.jar
10 org.maven.ide.eclipse.scm_0.9.2.zmyeclipse650200806.jar
11 org.maven.ide.eclipse_0.9.3.zmyeclipse650200806.jar

二、在线安装m2eclipse

1.Help -> Find and Install ->Search for new features to install->New Remote Site

1 name：m2eclipse
2 url：http://m2eclipse.sonatype.org/sites/m2e/0.10.0.20100209-0800/

2.点击Finish，开始自动搜索。这个链接之前是好用的，不过今天再下载总是提示错误，直接访问也提示内容找不到，看来是挪地方了。最后在官网找到这个帖子Where did http://m2eclipse.sonatype.org/sites/m2e go?根据提示找到了最新地址http://repository.sonatype.org/content/sites/forge-sites/m2e/
帖子内容

As of June 2013, that site has been shut down because M2Eclipse was moved to the Eclipse Foundation years ago.

You can access the archived M2Eclipse sites (including 0.12) here:

https://repository.sonatype.org/content/sites/forge-sites/m2e/

For more information on how to access current m2e releases, see http://eclipse.org/m2e/download/.

所以上面的地址变成了这样

1 name:m2eclipse
2 url:http://repository.sonatype.org/content/sites/forge-sites/m2e/0.10.0/S/20100209-0800/

再安装就没有问题了。

3.设置maven

Window->preferences，搜索maven，User Settings中选择本地maven配置文件，Update Settings->Apply->OK

三、问题

重启MyEclipse后，跳出异常

1 Eclipse is running in a JRE, but a JDK is required
2 Some Maven plugins may not work when importing projects or updating source folders.

具体的解决方案见这个链接http://www.blogjava.net/itvincent/archive/2010/07/25/327101.html

初一七月 2013-11-05 16:19 发表评论

Redis并发问题

初一七月 — Mon, 28 Jan 2013 11:23:00 GMT

摘要: Redis 并发阅读全文

初一七月 2013-01-28 19:23 发表评论

ActiveMQ报Address already in use异常

初一七月 — Fri, 27 Jul 2012 07:59:00 GMT

摘要: Spring ActiveMQ Address already in use异常阅读全文

初一七月 2012-07-27 15:59 发表评论

JMS规范及相关实现

初一七月 — Thu, 26 Jul 2012 09:41:00 GMT

JMS是一种应用于异步消息传递的标准API，作为Java平台的一部分，JMS可以允许不同应用、不同模块之间实现可靠、异步数据通信。

一些概念

JMS provider
    An implementation of the JMS interface for a Message Oriented Middleware (MOM). Providers are implemented as either a Java JMS implementation or an adapter to a non-Java MOM.
JMS client
    An application or process that produces and/or receives messages.
JMS producer/publisher
    A JMS client that creates and sends messages.
JMS consumer/subscriber
    A JMS client that receives messages.
JMS message
    An object that contains the data being transferred between JMS clients.
JMS queue
    A staging area that contains messages that have been sent and are waiting to be read. Note that, contrary to what the name queue suggests, messages don't have to be delivered in the order sent. A JMS queue only guarantees that each message is processed only once.
JMS topic
    A distribution mechanism for publishing messages that are delivered to multiple subscribers.

在JMS中，支持两种消息模型，点对点（Point-to-point）和发布-订阅(Publish and subscribe)，这两种模式分别对应于JMS中的两种消息目标（Message Destination）:队列及主题。

在点对点模型中，每个消息都有一个发送者和一个接收者，消息中介（broker）收到发送者的消息，会将消息放入队列中，而接收者请求并接收队列中的一条消息后，这条消息就会从队列中删除。消息队列中的每条消息只能投递给一个接收者，但并不意味着只能使用一个接收者从队列中取消息，根据业务需要，可以使用多个接收者同时从队列中请求消息，分担处理压力。但是需要注意的是，单个接收者收到的消息是按照发送顺序的，多个接收者因为多线程的关系，并不能保证收到的消息一定是原序的。

在发布-订阅模式中，消息会发送给一个主题，但是与点对点模式不同的是消息不再只被投递给一个接收者，而是所有此主题的订阅者都会收到该消息。

JMS消息类型

在JMS1.1规范中，定义了五种消息类型，分别为：
1.StreamMessage ：消息体是 Java 流，写入和读出都是顺序的
2.MapMessage ：消息体包含 key-value 对， key 为 String ， value 为基本类型，可以通过迭代器访问
3.TextMessage ：消息体是 String
4.ObjectMessage ：消息体是可序列化的 Java 对象
5.BytesMessage ：消息体是字节数组

可以通过 message.clearBody() 来清除消息体；但在消费端，消息体是只读的，针对消息的写操作都会抛出 MessageNotWritableException 异常

JMS消息头

所有消息的消息头都具体相同的字段，用于 JMS Client 以及 JMS Provider 对它们进行区别以及进行消息路由

1.JMSDestination

消息发送的目的地（队列或主题）；创建消息时可以设置 JMSDestination ，但是在发送完成时其值会更新为发送方所指定的 JMSDestination ，也就是说发送前该字段会被忽略；当消息被消费时，该字段的值与在它被发送时被设置的值是相同的

以下所有示例均基于ActiveMQ

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建2个目的地
Destination destination = session.createQueue("JMS.DEMO");
Destination destination2 = session.createQueue("JMS.DEMO2");

// 创建生产者
MessageProducer publisher = session.createProducer(destination);

// 设置传输模式
publisher.setDeliveryMode(DeliveryMode.PERSISTENT);

// 创建消息
TextMessage message = session.createTextMessage("Test Message");
// 设置消息的目的地为destination2
message.setJMSDestination(destination2);

// 发送消息
publisher.send(message);

System.out.println(message.getJMSDestination());

代码中，通过 message.setJMSDestination(destination2); 设置了 message 的 JMSDestination 消息头属性值，我们再看看其输出结果

queue://JMS.DEMO

通过这个例子可以看出，虽然在发送前设置了消息的目的地，但是发送后消息的目的地被重置了

2.JMSDeliveryMode

指明消息的传输模式，有两种：

DeliveryMode.PERSISTENT ：保证消息仅传一次， JMS Provider 服务停止后消息不会丢失；

DeliveryMode.NON_PERSISTENT ：消息最多传一次，消息会因 JMS Provider 停止后丢失；

同 JMSDestination 一样，在发送前设置的会被忽略

看下面的例子

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建目的地
Destination destination = session.createQueue("JMS.DEMO");

// 创建生产者
MessageProducer publisher = session.createProducer(destination);

// 设置传输模式
publisher.setDeliveryMode(DeliveryMode.PERSISTENT);
// 发送PERSISTENT消息
publisher.send(session.createTextMessage("PERSISTENT MESSAGE"));

// 设置传输模式
publisher.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
// 发送PERSISTENT消息
publisher.send(session.createTextMessage("NON_PERSISTENT MESSAGE"));

例子中分别发送了一条 PERSISTENT 的消息和一条 NON_PERSISTENT 的消息；当 Active MQ 重启后，启动消费端，收到的消息如下

PERSISTENT MESSAGE

该例子说明，在 JMS Provider 重启后， NON_PERSISTENT 消息丢失了，而 PERSISTENT 消息能正常被消费者消费

3.JMSMessageID

由 JMS Provider 指定的消息的唯一标识符；同上面的字段一样，在发送前设置的会被忽略，在发送完成时，由 JMS Provider 重置该字段

4.JMSReplyTo

发送端在发送消息时，可以指定该属性（为一个 JMSDestination ），表示期望收到客户端的响应；是否响应由消费端决定

如下面的例子：

发送端：

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建目的地
Destination destination = session.createQueue("JMS.DEMO");
Destination destination2 = session.createQueue("JMS.DEMO3");

// 创建生产者
MessageProducer publisher = session.createProducer(destination);

// 设置传输模式
publisher.setDeliveryMode(DeliveryMode.PERSISTENT);

// 创建消息
TextMessage message = session.createTextMessage("Test Message");
message.setJMSReplyTo(destination2);
// 发送消息
publisher.send(message);

接收端（可以根据情况决定是否需要回复）

public void onMessage(Message message) {
    try {
        System.out.println("Receive message: " + message);
        if (message.getJMSReplyTo() != null) {
            session.createProducer(message.getJMSReplyTo()).send(session.createTextMessage("This is a reply to"
                                                                                           + message.getJMSReplyTo()));
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

5.JMSRedelivered

当消费者收到带有 JMSRedelivered 的消息头时，表明该消息在过去传输过但没有被确认

JMS Provider 必须对该字段进行设置，当为 true 时即告知消费者该消息是重传的，消费者需要自行处理重复的消息

6.JMSExpiration

消息的过期时间，其值为当前时间加上存活时间（毫秒）；当存活时间设置为 0 时，该字段的值也被设置为 0 ，表示永不过期；

消费端在一般情况下都不会接收到过期的消息，但 JMS Provider 并不保证这一点；

下面的例子说明了如何设置消息的过期时间

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建目的地
Destination destination = session.createQueue("JMS.DEMO");

// 创建生产者
MessageProducer publisher = session.createProducer(destination);

// 设置传输模式
publisher.setDeliveryMode(DeliveryMode.PERSISTENT);

// 创建消息
TextMessage message = session.createTextMessage("Test Message");
// 发送消息
publisher.setTimeToLive(5000);
publisher.send(message);

7.JMSPriority

消息的优先级， 0 代表最低优先级， 9 代表最高优先级；一般 0~4 为普通优先级， 5~9 为加快优先级

JMS 规范里并没有要求 JMS Provider 严格按这个优先级来实现，但是尽可能实现加快优先级消息的传输在普通消息的前面

同 JMSDestination 一样，该字段在发送前被忽略，在发送完成时重置

消息属性

除了前面提到的消息头以外， JMS 消息还提供了对“属性值对”的支持，以对消息头进行扩展；消息属性主要用于消息选择器 (message selector 详见下文 )

1.属性名
属性名必须服务消息选择器的命名规则

2.属性值

可以是基本类型及其对象类型以及 Map 、 List 和 String

下面的例子中，消息带 HashMap 的属性

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建目的地
Destination destination = session.createQueue("JMS.DEMO");

// 创建生产者
MessageProducer publisher = session.createProducer(destination);

// 设置传输模式
publisher.setDeliveryMode(DeliveryMode.PERSISTENT);

// 创建消息
TextMessage message = session.createTextMessage("Test Message");
// 发送消息
message.setObjectProperty("myProp", new HashMap() {

    {
        this.put("key1", "value1");
        this.put("key2", "value2");
    }
});
publisher.send(message);

3.清除属性

JMS 不能清除单个属性，但可以通过 Message.clearProperties() 方法清除所有消息属性

JMS实现（Provider implementations）

要使用JMS，必须要有相应的实现来管理session以及队列，从Java EE1.4开始，所有的Java EE应用服务器必须包含一个JMS实现。

以下是一些JMS实现：

Apache ActiveMQ

Apache Qpid, using AMQP

BEA Weblogic (part of the Fusion Middleware suite) and Oracle AQ from Oracle

EMS from TIBCO

FFMQ, GNU LGPL licensed

JBoss Messaging and HornetQ from JBoss

JORAM, from the OW2 Consortium

Open Message Queue, from Sun Microsystems

OpenJMS, from The OpenJMS Group

RabbitMQ, using AMQP

Solace JMS from Solace Systems

SonicMQ from Progress Software

StormMQ, using AMQP

SwiftMQ

Tervela

Ultra Messaging from 29 West (acquired by Informatica)

webMethods from Software AG

WebSphere Application Server from IBM, which provides an inbuilt default messaging provider known as the Service Integration Bus (SIBus), or which can connect to WebSphere MQ as a JMS provider [5]

WebSphere MQ (formerly MQSeries) from IBM

Ref from:
1.http://en.wikipedia.org/wiki/Java_Message_Service
2.Spring in Action
3.http://goldendoc.iteye.com/blog/1155647

初一七月 2012-07-26 17:41 发表评论

MyEclipse安装Python插件PyDev

初一七月 — Tue, 17 Jul 2012 09:18:00 GMT

1.help->software updates->find and install

2.search for new features to install->next

3.new remote site

4.finish

5.next，接受声明

6.finish，开始下载所有相关文件，在verification中选择install all，然后重启MyEclipse

7.查看是否安装成功，help->about myeclipse enterprise workbench->plig-in details

至此插件安装完毕，其他使用方法及安装参考：
http://pydev.org/manual_101_install.html
http://www.ibm.com/developerworks/cn/opensource/os-cn-ecl-pydev/

初一七月 2012-07-17 17:18 发表评论

oracle分页查找时，start与size在ibatis中的设置

初一七月 — Fri, 13 Jul 2012 06:41:00 GMT

使用oracle + ibatis进行数据分页查找时，对传入的参数start与size，进行如下查找语句

select * from
  (select t.*, romnum rn from
    (select * from user
       where score > #score#
       order by $orderby$
     ) t
   where rownum <= #start# + #size# )
where rn > #start#

在数据量较少时，以上语句没有问题，但是在达到500w+数据量时，就会发生急剧的性能下降，经过测试，发现应该改为以下的语句，就可以避免，在千万数据以上仍可以在百毫秒得出结果

select * from
  (select t.*, romnum rn from
    (select * from user
       where score > #score#
       order by $orderby$
     ) t
   where rownum <= $start$ + $end$ )
where rn > #start#

因为ibatis会将#xxx#参数解析为PreparedStatement中的？，但是如果使用#start#+#size#，会产生?+?的语句，影响oracle语句动态解析，实际上这个参数在执行时完全可以先计算和，再作为一个值传入语句，采用$start$+$size$正是做到了这点，大大加快了执行速度

初一七月 2012-07-13 14:41 发表评论

查询系统负载---uptime命令

初一七月 — Wed, 10 Aug 2011 13:49:00 GMT

Linux系统监控的过程中少不了对主机运行时间和系统负责等信息进行查询，这时候就可以使用Linux uptime命令。uptime命令可以显示系统运行多久、当前有多少的用户登录、在过去的1，5，15分钟里平均负载时多少，其用法十分简单。

用法：直接输入uptime即可，以下显示输入uptime的信息：

04:03:58 up 10 days, 13:19, 1 user, load average: 0.54, 0.40, 0.20

1.04:03:58 当前时间

2.10 days, 13:19 系统已运行的时间，时间越大，说明你的机器越稳定

3.1 user 当前在线用户，是总连接数而不是用户数

4.0.54, 0.40, 0.20最近1分钟、5分钟、15分钟系统的平均负载

系统平均负载被定义为在特定时间间隔内运行队列中的平均进程数。如果一个进程满足以下条件则其就会位于运行队列中：

- 它没有在等待I/O操作的结果

- 它没有主动进入等待状态(也就是没有调用'wait')

- 没有被停止(例如：等待终止)

一般来说，每个CPU内核当前活动进程数不大于3，则系统运行表现良好！当然这里说的是每个cpu内核，也就是如果你的主机是四核cpu的话，那么只要uptime最后输出的一串字符数值小于12即表示系统负载不是很严重，当然如果达到20，那就表示当前系统负载非常严重。

初一七月 2011-08-10 21:49 发表评论

svn版本对比

初一七月 — Wed, 10 Aug 2011 13:19:00 GMT

要对项目的两个版本进行比对，查看哪些文件发生了改变，可以使用svn的版本比对功能，具体如下：

1.TortoiseSVN->Repo-browser，找到需要比对的项目工程，这里假设要对项目的trunk与tag版本1.1进行比较，并将trunk作为基础版本
2.右键trunk->Mark for comparison，然后找到1.1版本，右键->Show differences as unified diff，之后svn会弹出TortoiseUDiff窗口

对比结果以文本形式显示，格式如下

Index: com/service/SVNService.java
===================================================================
--- com/service/SVNService.java (/tag/1.1) (版本 227144)
+++ com/service/SVNService.java (/trunk) (版本 227097)
@@ -20,7 +20,8 @@

-if (!target.exists()) return;
+if (target.exists()) return;

通常情况下，第2-4行用黄背景显示，表示进行比较的两个版本，而以减号开头的行用红色背景，表示1.1版本有而trunk版本没有的内容，以加号开始的行用绿色背景显示，表示trunk有而1.1版本没有的内容，上面的结果显示，我们可能在tag版本里将判断条件从不存在返回改为了存在返回。

另外以@@开头并结尾的行，表示下面的变动所在的位置

初一七月 2011-08-10 21:19 发表评论

Apache 命令

初一七月 — Fri, 27 May 2011 10:25:00 GMT

启动

apache/bin/apachectl start

停止

apache/bin/apachectl stop

重启

apache/bin/apachectl restart

重启时不中断当前的连接

apache/bin/apachectl graceful

如果apache安装成为linux的服务的话，可以用如下的命令

启动

service httpd start

停止

service httpd stop

重启

service httpd restart

初一七月 2011-05-27 18:25 发表评论