flying.xu77
- 浏览: 4688 次
- 性别:
- 来自: 上海
-
最新评论
文章列表
/**
* int到byte[]
* @param i
* @return
*/
public static byte[] intToByteArray(int i) {
byte[] result = new byte[4];
//由高位到低位
result[0] = (byte)((i >> 24) & 0xFF);
result[1] = (byte)((i >> 16) & 0xFF);
result[2] = (byte)((i >> 8) & 0xFF);
r ...
int java.io.InputStream.read(byte[] b, int off, int len) throws IOException
API说明：
将输入流中最多 len 个数据字节读入字节数组。尝试读取多达 len 字节，但可能读取较少数量。以整数形式返回实际读取的字节数。
在输入数据可用、检测到流的末尾或者抛出异常前，此方法一直阻塞。
参数：
b - 读入数据的缓冲区。
off - 在其处写入数据的数组 b 的初始偏移量。
len - 要读取的最大字节数。
返回：
读入缓冲区的总字节数，如果由于已到达流末尾而不再有数据，则返回 -1。
...
qpid的client端有可能会由于某种原因与broker断开连接，如网络连接断开，broker的节点删除等等。
公司的项目需要用java编写一个Service，用来监听broker的消息。要求如果与broker断开后，必须尝试重新连接。
那应该完成以下一个步骤：
(1)检测到client与服务器断开。
(2)如果断开，尝试重新连接。
对于(1),javax.jms.Connection对象可以设置一个ExceptionListener对象，用来监听是否发生连接异常。
以下为client端的类
/**
* 该类负责监听MQ的消息。消息的消费者为{@link GCMSender ...
资源文件的读取：
项目目录为以下结构，其中src,resources目录都作为source目录。
project
|--src
|--jp
|--pset
|--Main.java
|--configs
|--test1.properties
|--resources
|--configs
|--test2.properties
方法1：
java.lang.Class.getResourceAsStream(String na ...