增加线程异步发送消息的方法一（Thread）

@RequestMapping(value="order/updateOrder.do")
public String  updateOrder(HttpServletRequest request,HttpServletResponse response){
final String ordId =request.getParameter("ordId");
String proDesc =request.getParameter("proDesc");
final String logisticnum =request.getParameter("logisticnum");
final String logisticcompany =request.getParameter("logisticcompany");
String stats =request.getParameter("stats");
final String tranNum =request.getParameter("tranNum");
final String openId =request.getParameter("openId");

System.out.println("订单状态stats：" + stats);
System.out.println("tranNum：" + tranNum);
System.out.println("openId：" + openId);
System.out.println("logisticnum：" + logisticnum);
System.out.println("logisticcompany：" + logisticcompany);

GoodsOrder order = new GoodsOrder();
order.setOrdId(ordId);
order.setProDesc(proDesc);
order.setLogisticnum(logisticnum);
order.setLogisticcompany(logisticcompany);
order.setrStatus(stats);

//获取当前时间：毫秒
long a = System.currentTimeMillis();
System.out.println("a :" +  a);

try
{
//更改订单状态
shopService.updateOrder(order);

//如果订单状态从 支付成功 改成 已发货，则给用户发送一条微信消息。
if (Integer.parseInt(stats) == 3)
{
//异步发送微信消息
new Thread()
{
public void run()
{
message.sendWxMessage(openId, tranNum, logisticcompany,logisticnum);
}
}.start();
//同步发送微信消息
//message.sendWxMessage(openId, tranNum, logisticcompany,logisticnum);
}

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

//计算 try 内语句的执行时间
long b = System.currentTimeMillis();
System.out.println("b :" +  b);
System.out.println(" b - a :" + (b - a));
return "redirect:/order/orderlist.do?currPage=1";
}

package com.starcloud.helpapp.wxMessage.service;

/**
*
* 项目名称：eduappweb
* 类名称：
* 类描述：
* 创建人：Administrator
* 创建时间：2016-5-28 下午02:53:01
* @version 1.0
*/
public interface Message
{

/**
*
* [简要描述]：推送微信消息
* [详细描述]：
*
* @param openId
* @param proName
* @param payfee
* @param phoneNum
* @param flag   1:购买成功提示消息 2：代言返利消息
*/
public void sendWxMessage(String openId,String tranNum,String logisticcompany,String logisticnum);
}

package com.starcloud.helpapp.wxMessage.service.impl;

import org.springframework.stereotype.Service;

import net.sf.json.JSONObject;

import com.starcloud.helpapp.common.Loger;
import com.starcloud.helpapp.common.utils.Tools;
import com.starcloud.helpapp.wxMessage.ConnectionUrlUtil;
import com.starcloud.helpapp.wxMessage.beans.MsgTemplateBean;
import com.starcloud.helpapp.wxMessage.common.Constant;
import com.starcloud.helpapp.wxMessage.service.Message;

@Service("Message")
public class MessageImpl implements Message
{

/**
*
* [简要描述]：推送微信消息
* [详细描述]：    1:订单状态改成已发货
*
* @param parameter
*/
public void sendWxMessage(String openId,String tranNum,String logisticcompany,String logisticnum)
{
JSONObject parameters = new JSONObject();
MsgTemplateBean bean = MsgTemplateBean.getMsgTemplageBean(tranNum,logisticcompany,logisticnum);
bean.setTouser(openId);
parameters = JSONObject.fromObject(bean);
System.out.println("parameters: " + parameters.toString());
//        else
//        {
//            //proName返利订单
//            MsgforDistributeBean bean = MsgforDistributeBean.getMsgTemplageBean(payfee,phoneNum,proName);
//            bean.setTouser(openId);
//            parameters = JSONObject.fromObject(bean);
//        }
Loger.logtxt("WxMessage", "发送消息"+parameters);
String access_token = getAccess_token();
if(null != access_token)
{
String returnstr = ConnectionUrlUtil.sendPost(Constant.SEND_MESSAGEURL+"?access_token="+access_token,parameters.toString());
try
{
JSONObject returnJson = JSONObject.fromObject(returnstr);

if(0 == returnJson.getInt("errcode"))
{
Loger.logtxt("WxMessage", "发送消息成功"+parameters);
}
else
{
Loger.logtxt("WxMessage", "发送消息失败"+parameters);
}
}
catch (Exception e)
{
e.printStackTrace();
}

}
else
{
//发送失败，获取token失败
Loger.logtxt("WxMessage", "发送消息失败，原因获取access_token失败  ");
}

}
/**
*
* [简要描述]：获取到access_token
* [详细描述]：
*
* @return
*/
public String getAccess_token()
{
String access_token = "";//公司的access_token
String access_token_json = ConnectionUrlUtil.sendPost(Constant.TOKEN_URL, "grant_type=client_credential&appid=" + Constant.APP_ID + "&secret="
+ Constant.APP_SECRET);
if(Tools.isNotEmty(access_token_json))
{
JSONObject tokenJson = JSONObject.fromObject(access_token_json);
if(null != tokenJson && null!=tokenJson.get("access_token"))
{
//ACCESS_TOKEN
access_token = tokenJson.getString("access_token");
}
}
return access_token;
}
}