Authored by ping

使用httpclient 回调

... ... @@ -11,6 +11,7 @@ import javax.annotation.Resource;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.tuple.Pair;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
... ... @@ -31,6 +32,7 @@ import com.yoho.service.model.union.response.UnionResponse;
import com.yoho.unions.common.constant.UnionConstant;
import com.yoho.unions.common.enums.ClientTypeEnum;
import com.yoho.unions.common.utils.DateUtil;
import com.yoho.unions.common.utils.HttpUtils;
import com.yoho.unions.dal.IAppActivateIdfaListDAO;
import com.yoho.unions.dal.IUnionLogsDAO;
import com.yoho.unions.dal.model.AppActivateIdfaList;
... ... @@ -260,9 +262,15 @@ public class UnionServiceImpl implements IUnionService {
// }
log.info("activateUnion in call url={}", url);
// 调用接口发送短信请求
AsyncFuture<String> response = service.get("union.activate", url, null, String.class, null);
String result = response.get();
log.info("activateUnion call union url={}, and result={}", url, result);
// AsyncFuture<String> response = service.get("union.activate", url, null, String.class, null);
// String result = response.get();
//改成httpclient方式调用
Pair<Integer, String> pair = HttpUtils.httpGet(url);
log.info("activateUnion call union success url={}, and result={}", url, pair);
} catch (Exception e) {
log.error("callback error with request={}", request, e);
}
... ...