📄 mm7sender.java
字号:
catch(Exception e){
e.printStackTrace();
MM7RSErrorRes error = new MM7RSErrorRes();
error.setStatusCode(-100);
error.setStatusText("系统错误！原因："+e);
return error;
}
}
private ByteArrayOutputStream getSendMessage(byte[] bcontent)
{
try{
/**在此加以判断，如果是长连接，则得到以前的连接，否则新建连接
* */
if (pool.getKeepAlive().equals("on")) {
if(this.TimeOutFlag==true)
{
SevereBuffer.append("TimeOutFlag=true\r\n");
if(pool.deleteURL(TimeOutWrap))
{
SevereBuffer.append(" TimeOutWrap="+TimeOutWrap);
SevereBuffer.append(" pool.deleteURL(TimeOutWrap)");
////Add by hudm 2004-06-07
/*String MMSCIP = (String)mm7Config.getMMSCIP().get(0);
int index = MMSCIP.indexOf(":");
String ip;
int port;
if(index == -1)
{
ip = MMSCIP;
port = 80;
}
else
{
ip = MMSCIP.substring(0,index);
port = Integer.parseInt(MMSCIP.substring(index+1));
}
client = new Socket(ip,port);*/
////end add by hudm
connWrap = pool.getConnWrap();
this.TimeOutWrap = connWrap;
if (connWrap != null) {
SevereBuffer.append(" connWrap != null");
client = connWrap.getSocket();
}
else
{
SevereBuffer.append(" client=null");
client = null;
}
}
else
{
SevereBuffer.append("deleteURL is false!");
return null;
}
}
else
{
//SevereBuffer.append("!767!TimeOutFlag==false");
connWrap = pool.getConnWrap();
this.TimeOutWrap = connWrap;
if(connWrap != null)
{
//SevereBuffer.append(" connWrap != null");
client = connWrap.getSocket();
SevereBuffer.append("!!!!client="+client);
/////Add by hudm 2004-06-07
if (connWrap.getUserfulFlag() == false || client.isConnected() == false) {
SevereBuffer.append("!771!connWrap.getUserfulFlag() == false || client.isConnected() == false");
pool.deleteURL(connWrap);
connWrap = pool.getConnWrap();
this.TimeOutWrap = connWrap;
}
if (connWrap.getAuthFlag() == true) {
AuthInfor = connWrap.getDigestInfor();
}
/////end add by hudm
}
else
client = null;
}
/*(connWrap != null)
{
SevereBuffer.append("!768!connWrap != null");
if (connWrap.getUserfulFlag() == false || client.isConnected() == false) {
//从连接池中删除该条连接
SevereBuffer.append("!771!connWrap.getUserfulFlag() == false || client.isConnected() == false");
pool.deleteURL(connWrap);
////////
connWrap = pool.getConnWrap();
this.TimeOutWrap = connWrap;
///////
//return null;
}
if (connWrap.getAuthFlag() == true) {
AuthInfor = connWrap.getDigestInfor();
}
}
else
{
SevereBuffer.append("!785!connWrap==null");
return null;
}*/
}
else {
String MMSCIP = (String)mm7Config.getMMSCIP().get(0);
int index = MMSCIP.indexOf(":");
String ip;
int port;
if(index == -1)
{
ip = MMSCIP;
port = 80;
}
else
{
ip = MMSCIP.substring(0,index);
port = Integer.parseInt(MMSCIP.substring(index+1));
}
client = new Socket(ip,port);
}
if(client != null){
SevereBuffer.append("!829!client != null and equals"+client);
sender = new BufferedOutputStream(client.getOutputStream());
receiver = new BufferedInputStream(client.getInputStream());
client.setSoTimeout(mm7Config.getTimeOut());
client.setKeepAlive(true);
sb = new StringBuffer();
sb.append(beforAuth);
sb.append(AuthInfor);
sb.append(afterAuth);
try {
sendBaos = new ByteArrayOutputStream();
SevereBuffer.append("!part of send message is:"+sb.toString()+"!\r\n");
sendBaos.write(sb.toString().getBytes());
sendBaos.write(bcontent);
return sendBaos;
}
catch (IOException e) {
//System.out.println("IOException!原因："+e);
SevereBuffer.append("IOException=" + e + "\r\n");
return null;
}
}
else
{
SevereBuffer.append("!853!client == null");
return null;
}
}catch(UnknownHostException uhe)
{
//System.out.println("UnknownHostExcepion!原因："+uhe);
SevereBuffer.append("UnknownHostExcepion="+uhe+"\r\n");
return null;
}
catch(SocketException se)
{
//System.out.println("SocketException!原因："+se);
SevereBuffer.append("SocketException="+se+"\r\n");
return null;
}
/**超时后，被捕获，认为该次发送失败，重新进行发送，当发送超过一定次数后，
* 即认为整个发送失败。返回失败信息。
* */
catch(InterruptedIOException iioe)
{
this.TimeOutFlag = true;
for(int j=0;j<mm7Config.getReSendCount();j++)
{
sendBaos = getSendMessage(bcontent);
if(sendBaos != null)
res = this.SendandReceiveMessage(sendBaos);
}
res.setStatusCode(-101);
res.setStatusText("超时发送失败！原因："+iioe);
SevereBuffer.append("[Comments={-101;超时发送失败！原因："+iioe+"}]\r\n");
return null;
}
catch(Exception e)
{
e.printStackTrace();
res.setStatusCode(-100);
res.setStatusText("系统错误！原因："+e);
SevereBuffer.append("[Comments={-100;系统错误！原因："+e+"}]\r\n");
return null;
}
}
private MM7RSRes SendandReceiveMessage(ByteArrayOutputStream sendbaos)
{
try{
/////////
//SevereBuffer.append("sendbaos="+sendbaos.toString());
////////
sender.write(sendbaos.toByteArray());
sender.flush();
if(this.receiveMessge())
{
res = parseXML();
return res;
}
else
{
MM7RSErrorRes error = new MM7RSErrorRes();
error.setStatusCode( -102);
error.setStatusText("接收失败！");
SevereBuffer.append("[Message_Type=MM7RSErrorRes]");
SevereBuffer.append("[Comments={-102;"+error.getStatusText()+"}]");
return error;
}
}catch(IOException ioe)
{
this.TimeOutFlag = true;
sendBaos = getSendMessage(this.TimeOutbCount);
if (sendBaos != null) {
res = SendandReceiveMessage(sendBaos);
if(res!=null)
{
this.TimeOutFlag = false;
return res;
}
else{
MM7RSErrorRes error = new MM7RSErrorRes();
error.setStatusCode( -103);
error.setStatusText("没有返回正确的消息");
SevereBuffer.append("[Message_Type=MM7RSErrorRes]");
SevereBuffer.append("[Comments={-103;" + error.getStatusText() + "}]");
return error;
}
/*if (res.getStatusCode() == MMConstants.RequestStatus.SUCCESS) {
this.TimeOutFlag = false;
return res;
}
else
{
MM7RSErrorRes error = new MM7RSErrorRes();
error.setStatusCode( -110);
error.setStatusText("原因:" + ioe);
SevereBuffer.append("[Message_Type=MM7RSErrorRes]");
SevereBuffer.append("[Comments={-103;" + error.getStatusText() + "}]");
return error;
}*/
}
else
{
MM7RSErrorRes error = new MM7RSErrorRes();
error.setStatusCode( -104);
//error.setStatusText("Socket不通！原因:" + ioe);
error.setStatusText(" " + ioe);
SevereBuffer.append("[Message_Type=MM7RSErrorRes]");
SevereBuffer.append("[Comments={-104;" + error.getStatusText() + "}]");
return error;
}
}
}
public boolean receiveMessge() throws IOException
{
try {
baos.reset();
boolean bReceive = false;
byte[] data = new byte[MMConstants.ARRAYLIMIT];
int word = -1;
int readline = -1;
int totalline = 0;
boolean flag = false;
boolean bHead = false;
int readlineOut = 1;
int envelopecount = 0;
while (1 > 0) {
if (flag)
break;
readline = receiver.read(data);
if (readline != -1) {
baos.write(data, 0, readline);
//System.out.println("baos==="+baos.toString());
totalline = totalline + readline;
if (baos.toString().indexOf("\r\n\r\n") < 0)
continue;
if (bHead == false) {
int httpindex = baos.toString().indexOf("HTTP/1.1");
if(httpindex != -1){
String httpCode = baos.toString().substring(httpindex + 8,
httpindex + 12).trim();
int httpsepindex = baos.toString().indexOf("\r\n\r\n");
if (httpCode.equals("401")) {
if (baos.toString().indexOf("Digest") != -1) {
if (ResendCount < mm7Config.getReSendCount()) {
ResendCount = ResendCount + 1;
pool.setInitNonceCount();
String clientAuthInfor = "";
String authInfor = "";
int authindex = baos.toString().indexOf(MMConstants.
AUTHENTICATION);
if (authindex > 0) {
int lineend = baos.toString().indexOf("\r", authindex + 1);
int linebeg = authindex +
MMConstants.AUTHENTICATION.length() +
1;
authInfor = baos.toString().substring(linebeg, lineend);
clientAuthInfor = setDigestAuth(authInfor);
}
int connectionindex = baos.toString().toLowerCase().indexOf(
MMConstants.CONNECTION);
int connlength = connectionindex +
MMConstants.CONNECTION.length() + 1;
int connectionend = baos.toString().indexOf("\r\n",
connectionindex);
String ConnectionFlag = "";
if (connectionindex != -1 && connectionend != -1)
ConnectionFlag = baos.toString().substring(connlength,
connectionend);
sb = new StringBuffer();
sb.append(beforAuth);
sb.append(clientAuthInfor);
sb.append(afterAuth);
sb.append(entityBody);
sender.write(sb.toString().getBytes());
sender.flush();
baos = new ByteArrayOutputStream();
data = new byte[MMConstants.ARRAYLIMIT];
int resline = -1;
int totalresline = 0;
boolean excuteFlag = false;
int httpseper = -1;
int contlen3 = -1;
while (1 > 0) {
resline = receiver.read(data);
if (resline == -1)
break;
baos.write(data, 0, resline);
totalresline += resline;
if (baos.toString().indexOf("\r\n\r\n") < 0)
continue;
if (excuteFlag == false) {
httpindex = baos.toString().indexOf("HTTP/1.1");
httpCode = baos.toString().substring(httpindex + 8,
httpindex + 12).trim();
int conlen1 = baos.toString().toLowerCase().indexOf(
MMConstants.CONTENT_LENGTH);
int conlen2 = baos.toString().indexOf("\r", conlen1);
contlen3 = Integer.parseInt(baos.toString().substring(
(conlen1 + MMConstants.CONTENT_LENGTH.length() + 1),
conlen2).trim());
httpseper = baos.toString().indexOf("\r\n\r\n");
if (httpCode.equals("200")) {
//还要再加判断客户端是否是长连接
ResendCount = 0;
excuteFlag = true;
if (ConnectionFlag.trim().toLowerCase().equals(
"keep-alive")) {
pool.setNonceCount(Integer.toString(Integer.
parseInt(
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -