?? syncmessagebean.java
字號:
package com.ll.smsbeans;
import java.io.Serializable;
import java.util.logging.Logger;
import com.ll.smsbeans.cmpp3.CmppCancelBuilder;
import com.ll.smsbeans.cmpp3.CmppCancelResp;
import com.ll.smsbeans.cmpp3.CmppPacket;
import com.ll.smsbeans.cmpp3.CmppPacketCommon;
import com.ll.smsbeans.cmpp3.CmppQueryBuilder;
import com.ll.smsbeans.cmpp3.CmppQueryResp;
import com.ll.smsbeans.cmpp3.CmppSubmitBuilder;
import com.ll.smsbeans.cmpp3.CmppSubmitResp;
/**
*
* <code>SyncMessengerBean</code> 通過MessengerBean采用同步方式發送submit,query,cancel數據包.
* Connection為已經連接的ConnectBean,<code>SyncMessengerBean</code>必須指定ConnectBean。
* <p>
*
* 原計劃寫這個類是為了讓人們比較方便的使用，可是實際上使用的時候不一定很方便。
* 特別要需要注意的是，對于sendSubmit來說，需要記錄返回的msgId，以便用于cancel Submit,和根據registerDelivery 查詢
* 短消息狀態。不能在這個類中實現，要不在使用的時候修改這個類，或者另外使用一個PacketListener記錄msgId。
* 這個類實現的即丑陋，又不太好用，在這里弄出來完全是為類演示一下關于這個類庫的使用方法。
* 在使用的時候需要單獨的將它放在一個線程中運行，以免造成事件阻塞。
*
* @author listlike <a href="mailto:listlike@hotmail.com">
* <i><listlike@hotmail.com></i></a>
*
*/
public class SyncMessageBean implements Serializable, PacketListener
{
static Logger _log;
/** 必須的連接bean */
private ConnectionBean connection = null;
private MessageBean messageBean = null;
/**
* 建立一個 <code>MessengerBean</code> 實例,并且注冊一個ConnectionBean。
*
* @param connection <code>ConnectionBean</code>
*/
public SyncMessageBean(ConnectionBean connection)
{
setConnection(connection);
}
/**
* <code>setConnection</code> 在建立對象后，設置一個ConnectionBean
*
* @param connection a <code>ConnectionBean</code>
*/
public void setConnection(ConnectionBean connection)
{
this.connection = connection;
messageBean = new MessageBean(connection);
messageBean.addPacketListener(this);
}
/**
* <code>getConnection</code>返回被這個對象使用的<code>ConnectionBean</code>。
*
* @return <code>ConnectionBean</code>
*/
public ConnectionBean getConnection()
{
return connection;
}
/**
* 發送一個Submit，當其回復包返回后，根據返回包返回是否成功發送這個包。
*
* @param preMessage 需要發送的submit對象。
* @param msgContent 需要發送的內容。
* @return 是否成功，0 成功,-1 發送失敗，>1同submitResp錯誤定義。
*/
public int sendSubmit(CmppSubmitBuilder preMessage, String msgContent)
{
//preMessage.setSequenceId(IdBuilder.getInstance().getSequenceId());
byte[] sb = new byte[0];
try
{
switch (preMessage.getMsgFmt())
{
case CmppPacketCommon.MSG_TYPE_ASCII :
sb = msgContent.getBytes("ASCII");
break;
case CmppPacketCommon.MSG_TYPE_BINARY :
sb = msgContent.getBytes();
break;
case CmppPacketCommon.MSG_TYPE_CHINESE :
sb = msgContent.getBytes("GBK");
break;
case CmppPacketCommon.MSG_TYPE_UCS2 :
sb = msgContent.getBytes("UnicodeBigUnmarked");
break;
case CmppPacketCommon.MSG_TYPE_WRITECARD :
sb = msgContent.getBytes();
break;
default :
sb = msgContent.getBytes("ASCII");
break;
}
} catch (Exception e)
{
// TODO: handle exception
}
return sendSubmit(preMessage, sb);
}
/**
* 發送一個Cancel，當其回復包返回后，根據返回包返回是否成功發送這個包。
*
* @param CmppCancelBuilder 需要發送的Cancel對象。
* @return 是否成功，0 成功,-1 發送失敗，>1同CancelResp錯誤定義。
*/
public int sendCancel(CmppCancelBuilder ccb)
{
int ErrCode = 0;
CmppCancelResp ccr = null;
// ccb.CreateNextSequenceId();
Packet sendPacket = ccb.builder();
messageBean.sendMessage(sendPacket);
Packet rp = (CmppCancelResp) syncPacketResp(sendPacket);
if (rp != null)
{
if (rp instanceof CmppCancelResp)
{
ccr = (CmppCancelResp) rp;
ErrCode = ccr.getSuccessId();
} else
ErrCode = -1;
} else
{
ErrCode = -1;
}
return ErrCode;
}
private Packet syncPacketResp(Packet sendPacket)
{
Packet respPack = null;
int respPacketCommandId =
0x80000000 | (0xff & ((CmppPacket) sendPacket).getCommandId());
while (respPack == null)
{
try
{
wait(1000);
} catch (Exception e)
{
}
//判斷是否超時！?。? SendPacketState sps =
SendPackStateList.getInstance().get(sendPacket);
if (sps != null)
{
if (System.currentTimeMillis() - sps.getSendTime() > 120000)
{
break;
}
}
//判斷是否受到正確的回復包
sps = SendPackStateList.getInstance().get(sendPacket);
if (sps != null)
{
if (sps.getState().getValue()
== SendPacketState.STATE_RESPONSED.getValue())
{
Packet rp = sps.getRespPacket();
if (rp instanceof CmppPacket)
{
if (((CmppPacket) rp).getCommandId()
== respPacketCommandId)
{
respPack = sps.getRespPacket();
break;
} else
break;
} else
break;
}
if (sps.getState().getValue()
== SendPacketState.STATE_FAILED.getValue())
break;
};
}
SendPackStateList.getInstance().remove(sendPacket);
return respPack;
}
/**
* 發送一個Query，當其回復包返回后，根據返回包返回是否成功發送這個包。
* @param cqb 查詢包
* @return 返回查詢結果，如果為null失敗。
*/
public CmppQueryResp sendQuery(CmppQueryBuilder cqb)
{
int ErrCode = 0;
CmppQueryResp cqr = null;
Packet sendPacket = cqb.builder();
messageBean.sendMessage(sendPacket);
return (CmppQueryResp) syncPacketResp(sendPacket);
}
public int sendSubmit(CmppSubmitBuilder preMessage, byte[] messgae)
{
int ErrCode = 0;
int msgMaxCount =
preMessage.getMsgFmt() == CmppPacketCommon.MSG_TYPE_ASCII
? 159
: 140;
int packetCount = messgae.length / msgMaxCount;
packetCount =
messgae.length % msgMaxCount == 0 ? packetCount : packetCount + 1;
Packet[] packetList = new Packet[packetCount];
int currPoint = 0;
int packetIndex = 0;
while (true)
{
int curLen =
(currPoint + msgMaxCount) < messgae.length
? msgMaxCount
: messgae.length - currPoint;
byte[] msgByte = new byte[curLen];
for (int i = 0; i < curLen; i++)
{
msgByte[i] = messgae[currPoint + i];
}
// preMessage.CreateNextSequenceId();
preMessage.setMsgContent(msgByte);
packetList[packetIndex] = preMessage.builder();
messageBean.sendMessage(packetList[packetIndex]);
packetIndex++;
currPoint += msgMaxCount;
if (currPoint >= messgae.length)
break;
}
if (packetIndex != packetCount)
{
ErrCode = -1;
return ErrCode;
}
Packet respPacket;
for (int i = 0; i < packetList.length; i++)
{
respPacket = syncPacketResp(packetList[i]);
if (respPacket == null)
{
ErrCode = -1;
break;
}
ErrCode = ((CmppSubmitResp) respPacket).getResult();
if (ErrCode != 0)
break;
}
for (int i = 0; i < packetList.length; i++)
{
SendPackStateList.getInstance().remove(packetList[i]);
}
return ErrCode;
}
/* （非 Javadoc）
* @see com.ll.smsbeans.PacketListener#receivedPacket(com.ll.smsbeans.PacketEvent)
*/
public void receivedPacket(PacketEvent pe)
{
notify();
}
/* （非 Javadoc）
* @see com.ll.smsbeans.PacketListener#sendFailed(com.ll.smsbeans.PacketEvent)
*/
public void sendFailed(PacketEvent pe)
{
notify();
}
/* （非 Javadoc）
* @see com.ll.smsbeans.PacketListener#sentPacket(com.ll.smsbeans.PacketEvent)
*/
public void sentPacket(PacketEvent pe)
{
//notify();
}
static {
_log = Logger.getLogger("com.ll.smsbeans.SyncMessageBean");
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -