亚洲欧美日本韩国,亚洲精品夜夜夜妓女网,国产亚洲综合成人91精品

天快黑了 — Tue, 24 Aug 2010 07:54:00 GMT

2个不同的MDB监听JBoss 4.2.3 上的同一个Topic (集成JBoss Messaging 1.4.2 SP1)�Q�Topic上的消息是BytesMessage。发一个消息到Topic上，2个MDB都会(x��)收到�q�个消息�?br />
但奇怪的是只有一个MDB能正常读取BytesMesage�Q�另一个MDB��d��BytesMessage.readBytes()始终�q�回-1

同样的测试程序，在WebLogic上就正常�?br />
JBoss怎么�?x��)发送同一个BytesMessage对象到所有的subscriber�Q�有��册��同样的问题吗�Q?

google了很长时��_(d��)��也尝试了很多�Ҏ(gu��)��Q�似乎没什么好的办法。一�U�方法是避免使用BytesMessage, �q�有一�U�方法就是��用反��，直接复制JBoss的BytesMessage实现�?br />

public void onMessage(Message msg) {

  BytesMessageProxy msgProxy = (BytesMessageProxy)msg;

        Class clazz = MessageProxy.class;
        Field field = clazz.getDeclaredField("message");
        field.setAccessible(true);
        JBossMessage rawMsg = (JBossMessage)field.get(msgProxy);

        BytesMessage newMsg = (BytesMessage)rawMsg.doCopy();

      // read data from newMsg
}

天快黑了 2010-08-24 15:54 发表评论

Java虚拟机探险之Class Loader

天快黑了 — Tue, 17 Aug 2010 02:47:00 GMT

众所周知�Q�所有的Java class文�g都是�?/span>JVM�Q�虚拟机�Q�加载�ƈ执行的�?/span>深入理解JVM对于我们提高Java技术和解决Java问题都有非常大的帮助�?/span>

JVM内部主要包括内存��理�?/span>Class Loader�Q�类加蝲器）(j��)两个部分。熟�(zh��n)�了内存��理�Q�我们就�?x��)清楚程序在内存中是怎么分配和执行的�Q�就能解��x��有和对象相关的问题（比如Memory Leak�Q�。理解了Class Loader�Q�就能解��x��有类找不刎ͼ�比如遇到NoClassDefFoundError�?/span>ClassNotFoundException�Q�或配置文�g找不到问题�?/span>

�q�次我们只讨�?/span>JVM�?/span>Class Loader�Q�下�ơ再讨论JVM的内存管理�?/span>

Class Loader的主要作用就是负责查扄��q�将其加载到内存中。有��的是，Java中的Class Loader也是�?/span>Java所写，��和普通的class一栗��这��׃�生了一个是鸡生蛋还是蛋生鸡的问题，到底�W�一�?/span>class��p��来加载呢�Q�我们稍后会(x��)来讨��个问题�?/span>

先来看一�?/span>Class Loader所��h��的特炏V�?/span>

1. �l�承关系

虽然Class Loader也是一�?/span>Java class�Q�但�q�里的��承不是指定义class时��用的extends关键字来实现的��承，而是指由属性来�l�持的��承关�p�R��即通过Class Loader的构造方法或其它�Ҏ(gu��)��昑ּ�的设�|�一个父Class Loader�?/span>

2. 代理关系

每一�?/span>Class Loader在接到请求去加蝲一个类之前�Q�默认，讉K��一个类的时候，��׃��(x��)由加载当前类�?/span>Class Loader��d��载被讉K��的类�Q�，它会(x��)首先��h��它的�?/span>Class Loader来尝试加载，依次往上，如果�?/span>Class Loader加蝲成功�Q�则直接�q�回�Q�子Class Loader不再查找�?/span>

否则依次往下查扑�ƈ加蝲。如果直到被��h��?/span>Class Loader也没有找到要加蝲的类�Q�则�?x��)出�?/span>NoClassDefFoundError�?/span>ClassNotFoundException

当然如果被请求的�c�d��l�加载到了内存中�Q�就不会(x��)触发�q�个查找�q�程了，而是直接�q�回已经加蝲的类�?/span>

我们来看一个例子，假设有图1中的Class Loader层次�Q?/span>

如果我们��h��Class Loader E��d��?/span>Test.class�Q�首先它�?x��)请求�?/span>Class Loader D��d��试加载。同�?/span>Class Loader D�?x��)先��h��它的�?/span>Class Loader C��d��试加�?/span>Test.class。当然这�?/span>Class Loader C找不�?/span>Test.class�Q�于是�{回由Class Loader D��d��载。最�l?/span>Class Loader D成功扑ֈ��?/span>D:"Test.class�Q��ƈ��其加蝲到内存中�?/span>

同样�Q�如果我们请�?/span>Class Loader F��d��?/span>Test3.class�?/span>Class Loader C�?/span>Class Loader D在各自的搜烦(ch��)范围内都找不�?/span>Test3.class。最�l�会(x��)�?/span>Class Loader F自己加蝲F:"Test3.class到内存中�?/span>

如果我们��h��Class Loader D��d��?/span>Test3.class�Q�最�l�就�?x��)出�?/span>NoClassDefFoundError�?/span>ClassNotFoundException

3. 同一�l�承铑֏�见�?/span>

在同一�?/span>Class Loader对象的��扉K��中，下面被加载的�c�d��以访问上面被加蝲的类�Q�反之则不可以�?/span>

同样以图1��Z��Q?/span>Test4.class可以讉K��?/span>D:"Test.class�?/span>C:"Test2.class

而如�?/span>D:"Test.class�?/span>C:"Test2.class��试讉K��Test4.class�Q�就�?x��)出�?/span>NoClassDefFoundError�?/span>ClassNotFoundException

4. 多个�l�承链不可见�?/span>

多个�l�承链之间彼此看不到�Ҏ(gu��)��Q�不能相互访问�?/span>

�q�以�?/span>1��Z��Q�如�?/span>Test4.class讉K��Test3.class�Q�或反过�?/span>Test3.class讉K��Test4.class�Q�都�?x��)引�?/span>NoClassDefFoundError�?/span>ClassNotFoundException

理解�?/span>Class Loader所��h��的特点，我们来看�?/span>JDK中都预置了哪�?/span>Class Loader。也�?/span>JVM启动旉��认创建的Class Loader。如�?/span>2

通过�?/span>2�Q�我们可以看�?/span>Bootstrap Class Loader�?/span>JVM中的��先Class Loader。它�?/span>JDK中唯一一个由C++所写的Class Loader�Q�它负责加蝲JDK的核心类�?/span>(rt.jar)以及(qi��ng)另外两个�?/span>Java所写的Class Loader�Q?/span>Ext Class Loader�?/span>App Class Loader�Q�。之后就功成�w�退�Q��{�?/span>Ext Class Loader�?/span>App Class Loader加蝲所有应用中用到的类�?/span>

一般我们的应用都是通过讄��CLASSPATH�Q�最�l�由App Class Loader来加载。根�?/span>Class Loader的��承关�p�，我们应用中的�c�d��以访�?/span>JDK的核心类库。反之则�?x��)出错�?/span>

我们再来看看WebLogic�?/span>Class Loader的层�ơ关�p�（如图4�Q�。如果需要，大家可以参考一�?/span>WebLogic�?/span>WAR�?/span>EAR的文件结构（如图3�Q?/span>

WLS中自定义了很多新�?/span>Class Loader�Q�当然他们的��先Class Loader都是JDK中的App (or System) Class Loader。我们来看一下每�?/span>Class Loader的职责�?/span>

1. JDK App (or System) Class Loader

l 负责加蝲WLS启动脚本�?/span>CLASSPATH中设�|�的�c?/span>

l 所有的�c�都�?x��)最先由它尝试加�?/span>

l 因�ؓ(f��)CLASSPATH的值在�q�行期不允许修改�Q�所以由�?/span>Class Loader加蝲的类在运行期不能被动态卸载（替换�Q?/span>

2. EJB Class Loader (1)

l 负责加蝲单独�?/span>EJB jar里的�c�R�?/span>

l 不同�?/span>EJB jar文�g�?x��)被不同实例�?/span>Class Loader加蝲�Q�因�?/span>EJB jar彼此之间互相看不到对�?/span>

3. WAR Class Loader (1)

l 负责加蝲单独�?/span>WAR里的�c?/span>

l 不同�?/span>WAR文�g�?x��)被不同实例�?/span>Class Loader加蝲�Q�因�?/span>WAR彼此之间互相看不到对�?/span>

4. EAR Class Loader

l 负责加蝲EAR里面�?/span>APP-INF下的�c?/span>

l 不同�?/span>EAR文�g�?x��)被不同实例�?/span>EAR Class Loader加蝲�Q�因�?/span>EAR彼此之间互相看不到对�?/span>

l 它下面有一�?/span>EJB Class Loader (2) 实例,负责加蝲EAR里面所有的EJB jar。因此，EAR中的EJB彼此之间可以看到�Ҏ(gu��)��

l EJB Class Loader (2) 下有多个WAR Class Loader (2) 实例。每个实例负责加�?/span>EAR里面的一�?/span>WAR。所以，EAR中的WAR彼此之间看不到对�?/span>

l �Ҏ(gu��)��l�承链规则，WAR可以看到所有的EJB�?/span>APP-INF下的所有类�?/span> EJB可以看到APP-INF下的所有类�Q�但反之则不可以

Class Loader虽然�U�Cؓ(f��)�c�d��载器�Q�但�q�不意味着只能用来加蝲Class�Q�我们还可以利用它来查找囄��和配�|�文件等资源。比如，我们�l�常使用getClass().getResourceAsStream(name)来查��N��|�文件。同��P��查找其它资源文�g的方式和上面一��P��也会(x��)先请求父Class Loader来负责查找�?/span>

�q�里�Q�我们只��单介�l�了Class Loader对于�cȝ��查找�Q�而关�?/span>Class Loader的具体加载、校验和初始化的�q�程�Q�感兴趣的朋友可以参考《深�?/span>Java虚拟机�?/span>

天快黑了 2010-08-17 10:47 发表评论

天快黑了 — Wed, 04 Aug 2010 09:40:00 GMT

大家不用兛_��E�序实际逻辑是否正确�Q�只是好奇，��Z��么这个程序会(x��)hang住不�q�行了？而且CPU�?x��)占�?00%

import java.util.HashMap;

public class TestLock {

private HashMap map = new HashMap();

public TestLock() {
Thread t1 = new Thread() {
public void run() {
for(int i=0; i<50000; i++) {
map.put(new Integer(i), i);
}
System.out.println("t1 over");
}
};

Thread t2 = new Thread() {
public void run() {
for(int i=0; i<50000; i++) {
map.put(new Integer(i), i);
}

System.out.println("t2 over");
}
};

t1.start();
t2.start();

}

public static void main(String[] args) {
new TestLock();
}
}

Dump thread�?x��)看刎ͼ��E�序hang刎ͼ�(x��)

"Thread-1" prio=6 tid=0x00c70bd8 nid=0x914 runnable [0x02ebf000..0x02ebfc68]
at java.util.HashMap.put(HashMap.java:420)
at TestLock$2.run(TestLock.java:20)

"Thread-0" prio=6 tid=0x00c70a50 nid=0x578 runnable [0x02e7f000..0x02e7fb68]
at java.util.HashMap.put(HashMap.java:420)
at TestLock$1.run(TestLock.java:11)

天快黑了 2010-08-04 17:40 发表评论

另类NoClassDefFoundError

天快黑了 — Thu, 29 Jul 2010 07:54:00 GMT

通常NoClassDefFoundError产生的原因都是由于用到的class在CLASSPATH中找不到�?br />
�q�有下面一�U�另�cȝ��NoClassDefFoundError�Q?br /> 1. Class A 调用 Class B
2. JVM��试加蝲Class B�Q��ƈ执行Class B的静态块
3. Class B的静态块内抛出RuntimeException�Q�从而导致JVM加蝲Class B��p�|
4. 之后�Q��Q何类只要调用Class B�Q�就�?x��)出现NoClassDefFoundError

大家可以�q�行下面的例子试一�?

1 public class B
2 {
3     static {
4         String s = null;
5         s.substring(0);
6     }
7 }

1 public class A
2 {
3     public static void main(String[] args)
4     {
5         try
6         {
7             B b = new B();
8         }
9         catch (Throwable e)
10         {
11             e.printStackTrace();
12         }
13
14         try
15         {
16             B b = new B();
17         }
18         catch (Throwable e)
19         {
20             e.printStackTrace();
21         }
22     }
23 }

天快黑了 2010-07-29 15:54 发表评论

Socket Programming Considerations (2)

天快黑了 — Wed, 28 Jul 2010 01:23:00 GMT

1. Socket ack (acknowledgement)

Socket ack是指�?/span>socket接收到数据之后，发送一�?/span>ack字符�?/span>(比如$ACK)�l?/span>socket发送方。这��P��socket发送方可以�Ҏ(gu��)��是否收到�?/span>ack判断�Ҏ(gu��)��是否收到了数据�?/span>

Socket ack是显�C�的在应用程序中加入的一�U�通讯协议。如果不使用ack�Q�在socket通讯中，可能�?x��)丢失数据�?/span>

比如�Q?/span>socket client要连�l�的�l?/span>socket server发�?/span>100条消息。如果我们在server收到�W?/span>50条消息的时候，��kill�?/span>server。那么查�?/span>client端发送的log�Q�可�?/span>client端成功发送了51条。只有当client端发送第52条消息的时候才遇到异常。这��L(f��ng)��51条消息就丢失了�?/span>

所以�ؓ(f��)了确保数据传输的准确性，我们可以引入ack协议。有时我们不仅要��保server不但收到了数据，而且�q�要保证server成功处理了数据。这�Ӟ��可以�{?/span>server成功处理完数据之后，再给client�?/span>ack�?/span>

2. Socket Keep Alive

Socket�q�接像数据库�q�接一��P��属于重量型资源。如果我们频�J�的创徏socket、发�?/span>/接收数据、关�?/span>socket�Q�那么会(x��)有很大一部分旉��费�?/span>socket的创建和关闭上�?/span>

所以，如果我们�l�常需要与同一�?/span>socket地址发�?/span>/接收数据�Ӟ��应该考虑只创��Z��?/span>socket�Q�然后一直��用这�?/span>socket对象发�?/span>/接收数据�?/span>

3. Heartbeat

通常�Q�我们会(x��)讄��socket�?/span>receive timeout。这��P��如果我们一直打开着socket (keep alive)�Q?/span> 而很长时间又没有数据通讯�Q?/span>socket接收方就�?/span>timeout�Q�最�l�导致打开的连接坏掉�?/span>

如果很长旉��没有数据通讯�Q�防火墙或代理服务器也可能会(x��)关闭打开�?/span>socket�q�接�?/span>

所以�ؓ(f��)了保证打开�?/span>socket�q�接一直可用，如果一�D�|��间没有数据进行通讯�Q�或指定一个时间间隔）(j��)�Q�我们可以显�C�的发送一�?/span>heartbeat消息(比如: $HRT)�l�对方，从而保证连接不�?x��)被异常关闭�?/span>

4. Socket Close

每一个socket对象�?x��)持有一个socket descriptor (其实��是file descriptor)�Q�操作系�l�对于socket descriptor有一个最大限�?/span>。因此当socket不再使用�Ӟ��一定要记得关闭�Q�即�?/span>socket�q�接��p�|或出现异常，只要socket对象不�ؓ(f��)null�Q�一定要记得关闭�?/span>

下面图显�C�Z��Q�当socket关闭�Ӟ��socket的状态变�?/span>(socket状态可以通过netstat命��o(h��)查看)。更详细的解释，可以google一下�?br />

当主动一方调�?/span>close(先调�?/span>close)时的状态变�?/span>:

ESTABLISHED -> FIN_WAIT_1-> FIN_WAIT_2 -> TIME_WAIT -> CLOSED

当被动一方调�?/span>close(后调�?/span>close)时的状态变�?/span>:

ESTABLISHED -> CLOSE_WAIT -> LAST_ACK -> CLOSED

通常�Q?/span>TIME_WAIT 是正常状态，�q�一�D�|��?/span>(2MSL, 1�?/span>4分钟)��׃��(x��)自动消失.

我们需要特别注�?/span>CLOSE_WAIT 状态：(x��)

1�Q?span style="font: 7pt 'Times New Roman'"> 如果很长旉��才消失，表明socket server处理太慢�Q�很�?/span>client已经�q�接�?/span>server�Q�发送完数据�q?/span>close了�?/span>

2�Q?span style="font: 7pt 'Times New Roman'"> 如果一直也不消失，表明�?/span>socket没有正常close (�Ҏ(gu��)��已经close�?/span>)

5. SO_REUSEADDR Option

�?/span>socket��d��调用close的时候，从上面可以知道，它最�l�会(x��)�q�入TIME_WAIT 状态，需要过1�?/span>4分钟�Q�才能完�?/span>close�?/span>

�?/span>socket处于TIME_WAIT 状态时�Q�它仍然占用正在使用�?/span>IP/PORT。这��P��如果我们的程�?/span>(比如socket server)使用了一个固定的IP/PORT�Q�当socket处于TIME_WAIT 状态时�Q�程序将不能立即重启�Q�会(x��)出现端口占用错误�?/span>

Socket提供了一�?/span>setReuseAddress()�Ҏ(gu��)��Q�可以设�|�当socket处于TIME_WAIT 状态时�Q�是否允许其它进�E�绑定这个端口�?/span>

如果我们正在开�?/span>socket server�Q�一定要记得调用ServerSocket.setReuseAddress(true).

Client socket也有�q�个�Ҏ(gu��)��Q�而且有时可能需要指�?/span>client�q�接server时所使用的本�?/span>IP/PORT(一般不用指明，�pȝ��?x��)随机选择一�?/span>PORT)。但实际��试�Q�在client socket上设�|�这个方法在Windows�?/span>Solaris下�ƈ不�v作用。当socket处于TIME_WAIT 状态时�Q�重�?/span>client仍然出现端口占用错误。上�|�搜索了很长旉��Q�很多�h都碰��C��q�个问题�Q�可能是操作�pȝ��底层socket实现问题。因为测试��?/span>C语言开发的socket client�Q�同样也有这个错误。有��LINUX下好用，�q�有��是可以��试修改tcp_time_wait_interval来减��?/span>TIME_WAIT�{�待旉��

天快黑了 2010-07-28 09:23 发表评论

Socket Programming Considerations (1)

天快黑了 — Mon, 26 Jul 2010 01:31:00 GMT

�W�一�ơ开博，�W�一�ơ写文章。文�W�不好，只是记录一下个人心得�?br />
最�q�一直在做Socket�E�序�Q�这里把一些Socket�E�序的注意事��Ҏ(gu��)�ȝ��一下。今天先说说Socket中的Timeout�Q�其它的下次补全�?br />

1. Socket Timeout

�?/span>Socket�E�序的时候需要注意设�|�下面的timeout�Q�避免对�Ҏ(gu��)��有响应的时候，��D��Socket�E�序挂�v或等待时间过�?/span>

1.1 Accept Timeout

Accept timeout 仅对ServerSocket有用�?/span>ServerSocket 使用accept()�Ҏ(gu��)��来监听客��L(f��ng)��Socket的连接�?/span>

默认�Q?/span>ServerSocket.accept() �Ҏ(gu��)��?x��)一直阻塞直到有客户端来�q�接。通常�Q�我们不需要设�|?/span>accept timeout.

但有时候特�D�情况，�q�是要考虑讄��accept timeout.

比如: �E�序A�l�程�?/span>B发了一�?/span>JMS消息�Q�然后程�?/span>A启动一�?/span>Socket Server�Q�想通过socket�{�待接收�E�序B的返回消息。如果不讄��accept timeout, �q�且�E�序B因�ؓ(f��)某些原因一直不能连�?/span>Socket Server�Q�最�l�会(x��)��D��E�序A挂�v�?/span>

Accept Timeout可以�q�样讄��Q?/span>

ServerSocket serverSocket = new ServerSocket(5555);

serverSocket.setSoTimeout(5000); // in milliseconds

while (true) {

Socket socket = serverSocket.accept();

…

}

1.2 Connect Timeout

�?/span>Client端连�?/span>Server端的时候，可以指定Connect Timeout

如果没有指定�Q�会(x��)使用操作�pȝ��的默认�?/span>:

OS	Default TCP timeout
BSD	75 seconds
Linux	189 seconds
Solaris	225 seconds
Windows XP	21 seconds

Connect Timeout可以�q�样讄��Q?/span>

SocketAddress socketAddress = new InetSocketAddress(host, port);

socket = new Socket();

socket.connect(socketAddress, connectTimeout);

1.3 Receive Timeout

�?/span>socket从另一�Ҏ(gu��)��收数据时�Q�可以设�|?/span>Receive Timeout

默认没有timeout�Q?/span>socket�?x��)一直阻塞直到有数据可读取�?/span>

Receive Timeout可以�q�样讄��Q?/span>

Socket socket = new Socket(host, port);

socket.setSoTimeout(timeout);

1.4 Send Timeout

Send Timeout�?/span>socket�l�另一方发送数据时使用的�?/span>

不过Java里没有办法设�|?/span>Send Timeout.

当然�Q?/span>socket发送数据的时候，�?x��)首先发送到本机OS的一�?/span>buffer内。一般只要一�ơ发送的数据不是很大�Q�即使对�Ҏ(gu��)��h��暂时不能接收数据�Q�也不会(x��)��D��发送方挂�v�?/span>

天快黑了 2010-07-26 09:31 发表评论