Thu, 06 Aug 2015 01:26:00 GMT

摘要: mysql触发器，5.6版�?nbsp; 阅读全文

Wed, 08 Jul 2015 10:37:00 GMT

server.xml里，connect修改为：

               connectionTimeout="20000"
               redirectPort="8443"
       useBodyEncodingForURI="true"
    URIEncoding="UTF-8"
      />

��无�?/a> 2015-07-08 18:37 发表评论

myeclipse参数配置

Wed, 08 Jul 2015 10:33:00 GMT

1.myeclipse参数配置-解决代码不提�C�Z��保存�{�问�?下蝲后去�?txt�Q�然后导入myeclipse里的prefrences.
/Files/zhanglijun33/myeclipse参数配置-解决代码不提�C�Z��保存�{�问�?epf.txt
2.myeclipse的启动参敎ͼ�"D:\install\myeclipse10.7\MyEclipse 10\myeclipse.exe" -clean -Xms256m -Xmx768m -XX:MaxNewSize=256m -XX:MaxPermSize=768m

��无�?/a> 2015-07-08 18:33 发表评论

apache+jk+tomcat集群+session同步

Wed, 08 Jul 2015 10:26:00 GMT

摘要: tomcat 集群阅读全文

��无�?/a> 2015-07-08 18:26 发表评论

Wed, 08 Jul 2015 10:23:00 GMT

原因�Q�中文参数字�W�编码有问题�Q�在�E�序里调试的时候虽然不是�ؕ码，但数据库依旧不认识。这需要在jdbc.mysql.url里指定数据库使用的字�W�编码：utf-8.
jdbc.properties�?/span>
mysql.jdbc.url=jdbc:mysql://192.168.1.246:3306/wxb_site1?useUnicode=true&characterEncoding=utf-8
jndi的写法： context.xml里的写法�Q?lt;Resource name="jndi/wxb_site" auth="Container"
      type="javax.sql.DataSource" username="root" password="root"
      driverClassName="com.mysql.jdbc.Driver" url="jdbc:mysql://192.168.1.246:3306/wxb_site1?useUnicode=true&characterEncoding=utf-8"
   maxActive="100" maxIdle="10" maxWait="-1"/>

��无�?/a> 2015-07-08 18:23 发表评论

JMS服务器openJms入门

Tue, 08 Sep 2009 03:25:00 GMT

�? 先可以到�|�站上下载最新的openjms版本�Q�然后启动bin下的startup.bat��启动服务了�Q�然后可以启动admin.bat�q�入��理界面�Q�非必要步骤�Q�，然后分别�q�行samples下的basic例子��可以看到效果了�Q�当然以前有��文章介�l�的不错�Q�可以参考一下，不过旉��上比较老了�Q�做为参�? �q�是可以的�?br />
本文介绍开源的JMS服务器openJms�Q�及怎样使用openJms来构建系�l�之间健全、高度可用的通讯�Q�从而简化企业��应用的开发�? openJms�W�合SUN的JMS API 1.0.2规范�Q�支持消息队列，�q�支持消息传递的发布/订阅模式�Q�本文先��q��l�服务的搭徏及JMS的非�l�构化消息发送和接收�q�行说明�?br />
JMS 有五�U�消息类型。三�U�结构化或半�l�构化的消息�c�d��Q�MapMessage、ObjectMessage �? StreamMessage�Q�以及两�U�非�l�构化的或自由格式的消息�c�d��Q�TextMessage �? BytesMessage�Q�。而这里虽然我们只寚w��l�构化消息进行说明，但非�l�构化的消息格式却能够更好地�q�行交互操作�Q�因为它们在消息上很��利用结构，在此基础上与XML再进行结合，��能方便的进行更好的扩展�Q�XML相关��化操作参考《Jaxb来实现Java-XML的�{换》�?br />
下面具体来介�l�服务器搭徏�Q�在http://openjms.sourceforge.net/downloads.html下蝲openJms�Q�解压后可以直接使用�Q�在 "openjms-0.7.6.1"bin 里，有openJms的运行脚本，执行 startup 启动�Q�弹��Z��个新的窗口，服务��p��行在新窗口内�Q�shutdown 为停止命令：

服务�q�行后，��可以开始��用JMS服务了，��x��服务搭徏完毕�Q�简单得不能再简单了�?br />
下面是消息发送和接收的开发，开发中需要的jar包在"openjms-0.7.6.1"lib里可以找刎ͼ�
openjms-0.7.6.1.jar
jms-1.0.2a.jar
exolabcore-0.3.7.jar
commons-logging-1.0.3.jar

把上面的�c�d��加入到项目中�Q�下面是消息发送服务的代码�Q?br />
package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;

public class QueueSend {
    public static void main(String[] args) {
        try {
            //取得JNDI上下文和�q�接
            Hashtable properties = new Hashtable();
            properties.put(
                Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            //openJms默认的端口是1099
            properties.put(Context.PROVIDER_URL,
                 "rmi://localhost:1099/");
            Context context = new InitialContext(properties);

            //获得JMS信息�q�接队列工厂
            QueueConnectionFactory queueConnectionFactory =
                (QueueConnectionFactory) context.lookup(
                    "JmsQueueConnectionFactory");
            //获得JMS信息�q�接队列
            QueueConnection queueConnection =
                queueConnectionFactory.createQueueConnection();
            //产生队列Session�Q�设�|�事务�ؓfalse�Q�自动应�{�消息接�?br />             QueueSession queueSession =
                queueConnection.createQueueSession(
                    false,
                    Session.AUTO_ACKNOWLEDGE);

            //获得默认内徏在JMS里的队列之一�Q�queue1
            Queue queue = (Queue) context.lookup("queue1");
            //产生JMS队列发送器
            QueueSender queueSender =
                queueSession.createSender(queue);
            //发送数据到JMS
            TextMessage message = queueSession.createTextMessage();
            message.setText("Hello, I'm openJms.");
            queueSender.send(message);

            System.out.println(
                ""信息写入JMS服务器队�?);

            //以下做清除工作，代码�?br />             // ... ...

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

执行�E�序发送消息，然后打开JMS控制収ͼ��?admin 命��o启动��理�q�_��Q�点击菜单Actions�Q�Connections�Q�online�Q�出现界面如下：

可以看到JSM默认的队列queue1里已�l�有1条消息了�Q�而其他的队列�q�是�I�着的�?br />
下面我们来看看消息接收服务的代码�Q?br />
package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
public class QueueReceiveSynchronous {
    public static void main(String[] args) {
        try {
            //取得JNDI上下文和�q�接
            Hashtable properties = new Hashtable();
            properties.put(
                Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            properties.put(Context.PROVIDER_URL,
                "rmi://localhost:1099/");
            Context context = new InitialContext(properties);

            //获得JMS信息�q�接队列工厂
            QueueConnectionFactory queueConnectionFactory =
                (QueueConnectionFactory) context.lookup(
                    "JmsQueueConnectionFactory");

            //获得JMS信息�q�接队列
            QueueConnection queueConnection =
                queueConnectionFactory.createQueueConnection();

            //启动接收队列�U�程
            queueConnection.start();
            //产生队列Session�Q�设�|�事务�ؓfalse�Q�自动应�{�消息接�?br />             QueueSession queueSession =
                queueConnection.createQueueSession(
                    false,
                    Session.AUTO_ACKNOWLEDGE);
            //获得默认内徏在JMS里的队列之一�Q�queue1
            Queue queue = (Queue) context.lookup("queue1");
            //产生JMS队列接收�?br />             QueueReceiver queueReceiver =
                queueSession.createReceiver(queue);
            //通过同步的方法接收消�?br />             Message message = queueReceiver.receive();
            String messageText = null;
            if (message instanceof TextMessage)
                messageText = ((TextMessage) message).
                    getText();
            System.out.println(messageText);
            //以下做清除工作，代码�?br />             // ... ...

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

�~�译后运行接收信息服务，可以看到接收到�ƈ打印之前发送的消息�Q�再看看控制収ͼ�发现queue1的消息队列变�?�Q�消息已被读取，消息发送和接收到此�l�束�?br />

上篇openJms介绍 (一) 提到了openJms的构建及消息的发送和接收�Q�这��主要了解消息的发布和订阅。JMS 的发�?订阅模型定义了如何向一个内容节点发布和订阅消息�Q�内容节点也叫主�?topic)�Q�主题是为发布�?publisher)和订阅�? (subscribe) 提供传输的中介。发�?订阅模型使发布者和订阅者之间不需要直接通讯�Q�如RMI�Q�就可保证消息的传送，有效解决�pȝ��间耦合问题�Q�当然有�q�个需要才行）�Q�还有就是提供了一对一、一对多的通讯方式�Q�比较灵�z�R�?br />
先介�l�JMS�?个概念，持久订阅模式和非持久订阅模式�Q�其实也是发�?订阅模型在可靠性上提供�?�U�方式：

非持久订阅模式：只有当客��L��处于�Ȁ�zȝ��态，也就是和JMS 服务器保持连接的状态下�Q�才能接收到发送到某个Topic的消息，而当客户端处于离�U�状态时�Q�则�q�个旉��D�发到Topic的消息将会永�q�接收不到�?br />
持久订阅模式�Q�客��L��向JMS 注册一个识别自��p�n份的ID�Q�当�q�个客户端处于离�U�时�Q�JMS 服务器会��个ID 保存所有发送到主题的消息，当客户再�ơ连接到JMS 服务器时�Q�会�Ҏ��自己的ID 得到所有当自己处于��ȝ��时发送到主题的消息，��x��息永�q�能接收到�?br />
下面我们��接着来看openJms在发�?订阅模式上的表现�Q�由于篇�q�关�p�，在这里只讲述非持久订阅模式，持久订阅模式可以�Ҏ��JMS的标准来试�?br />
消息发布的代码如下：

package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
public class TopicPublish {
    public static void main(String[] args) {
        try {
            //取得JNDI上下文和�q�接
            Hashtable properties = new Hashtable();
            properties.put(
                Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            //openJms默认的端口是1099
            properties.put(Context.PROVIDER_URL, "rmi://localhost:1099/");
            Context context = new InitialContext(properties);
            //获得JMS Topic�q�接队列工厂
            TopicConnectionFactory factory =
                (TopicConnectionFactory) context.lookup(
                    "JmsTopicConnectionFactory");

            //创徏一个Topic�q�接�Q��ƈ启动
            TopicConnection topicConnection = factory.createTopicConnection();
            topicConnection.start();

            //创徏一个Topic会话�Q��ƈ讄��自动应答
            TopicSession topicSession =
                topicConnection.createTopicSession(false,
                        Session.AUTO_ACKNOWLEDGE);

            //lookup 得到 topic1
            Topic topic = (Topic) context.lookup("topic1");
            //用Topic会话生成Topic发布�?br />             TopicPublisher topicPublisher = topicSession.createPublisher(topic);

            //发布消息到Topic
            System.out.println("消息发布到Topic");
            TextMessage message = topicSession.createTextMessage
                ("你好�Q�欢�q�定购Topic�c�L��?);
            topicPublisher.publish(message);

            //资源清除�Q�代码略 ... ...
        } catch (NamingException e) {
            e.printStackTrace();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

而订阅消息的接收有同步的和异�?�U�，他们分别使用receive()和onMessage(Message message)�Ҏ��来接收消息，具体代码�Q?br />
同步接收�Q?br />
package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
public class TopicSubscribeSynchronous {

    public static void main(String[] args) {
        try {
            System.out.println("定购消息接收启动�Q?);
            //取得JNDI上下文和�q�接
            Hashtable properties = new Hashtable();
            properties.put(Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            properties.put(Context.PROVIDER_URL, "rmi://localhost:1099/");
            Context context = new InitialContext(properties);

            //获得Topic工厂和Connection
            TopicConnectionFactory factory =
                (TopicConnectionFactory) context.lookup(
                    "JmsTopicConnectionFactory");
            TopicConnection topicConnection = factory.createTopicConnection();
            topicConnection.start();

            //创徏Topic的会话，用于接收信息
            TopicSession topicSession =
                topicConnection.createTopicSession(
                    false,
                    Session.AUTO_ACKNOWLEDGE);

            //lookup topic1
            Topic topic = (Topic) context.lookup("topic1");
                    //创徏Topic subscriber
            TopicSubscriber topicSubscriber =
                topicSession.createSubscriber(topic);
            //收满10条订阅消息则退�?br />             for (int i=0; i<10; i++) {
                //同步消息接收�Q��用receive�Ҏ��Q�堵塞等待，直到接收消息
                TextMessage message = (TextMessage) topicSubscriber.receive();
                System.out.println("接收订阅消息["+i+"]: " + message.getText());
            }
            //资源清除�Q�代码略 ... ...
            System.out.println("订阅接收�l�束.");
        } catch (NamingException e) {
            e.printStackTrace();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

非同步接�Ӟ��

package javayou.demo.openjms;
import java.util.*;
import javax.jms.*;
import javax.naming.*;
public class TopicSubscribeAsynchronous implements MessageListener {
    private TopicConnection topicConnection;
    private TopicSession topicSession;
    private Topic topic;
    private TopicSubscriber topicSubscriber;

    TopicSubscribeAsynchronous() {
        try {
            //取得JNDI上下文和�q�接
            Hashtable properties = new Hashtable();
            properties.put(
                Context.INITIAL_CONTEXT_FACTORY,
                "org.exolab.jms.jndi.InitialContextFactory");
            properties.put(Context.PROVIDER_URL, "rmi://localhost:1099/");
            Context context = new InitialContext(properties);

            //取得Topic的连接工厂和�q�接
            TopicConnectionFactory topicConnectionFactory =
                (TopicConnectionFactory) context.lookup(
                    "JmsTopicConnectionFactory");
            topicConnection = topicConnectionFactory.createTopicConnection();

            //创徏Topic的会话，用于接收信息
            topicSession =
                topicConnection.createTopicSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            topic = (Topic) context.lookup("topic1");

            //创徏Topic subscriber
            topicSubscriber = topicSession.createSubscriber(topic);
            //讄��订阅监听
            topicSubscriber.setMessageListener(this);

            //启动信息接收
            topicConnection.start();
        } catch (NamingException e) {
            e.printStackTrace();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        System.out.println("非同步定购消息的接收�Q?);
        try {
            TopicSubscribeAsynchronous listener =
                new TopicSubscribeAsynchronous();
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    //收到订阅信息后自动调用此�Ҏ��
    public void onMessage(Message message) {
        try {
            String messageText = null;
            if (message instanceof TextMessage)
                messageText = ((TextMessage) message).getText();
            System.out.println(messageText);
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

�~�译好后�Q�启动openJms服务�Q�打开admin��理収ͼ��Z��q�行方便�Q�这里先列出三个�cȝ��q�行命��o�Q?br /> java -cp ."; -Djava.ext.dirs=."lib; javayou.demo.openjms.TopicPublish
java -cp ."; -Djava.ext.dirs=."lib; javayou.demo.openjms.TopicSubscribeSynchronous
java -cp ."; -Djava.ext.dirs=."lib; javayou.demo.openjms.TopicSubscribeAsynchronous

先运�?个接收命令，再运行发布命令，可以看到控制台的Topic有消息接�Ӟ��q�且接收1�?都有消息接收的提�C�，到此完成演示�Q�由于是非持久订阅，所以可以看到控制台上的Topic消息条数不会减少�?

��无�?/a> 2009-09-08 11:25 发表评论

Thu, 27 Nov 2008 06:48:00 GMT

摘要: ��目性能优化相关�Q�oscache实际应用,Cookie的�؜乱及解决阅读全文

��无�?/a> 2008-11-27 14:48 发表评论

Mon, 17 Nov 2008 06:19:00 GMT

摘要: hqlEdit的��?spring service层的��试阅读全文

��无�?/a> 2008-11-17 14:19 发表评论

Mon, 10 Nov 2008 03:51:00 GMT

1传中文之前的准备
<%
String a = "我是立军";
a = URLEncoder.encode(a,"gbk");
%>

试验

2.接收 <%
String actionName=new String(request.getParameter("actionName").getBytes("iso8859_1"));
%>
actionName:<%=actionName %>

��无�?/a> 2008-11-10 11:51 发表评论

91精品久久久久久9s密挑,国产精品日韩电影,禁断一区二区三区在线

myeclipse参数配置

apache+jk+tomcat集群+session同步

JMS服务器openJms入门