189 8069 5689
这篇文章给大家介绍怎么在Java中按时间梯度异步回调接口，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。
我们提供的服务有：成都网站设计、做网站、微信公众号开发、网站优化、网站认证、砀山ssl等。为上千家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务，是有科学管理、有技术的砀山网站制作公司
用到的技术如下：
•http请求库，retrofit2
•队列，LinkedBlockingQueue
•调度线程池，ScheduledExecutorService
3. 主要代码说明
3.1 回调时间梯度的策略设计
采用枚举来对策略规则进行处理，便于代码上的维护，该枚举设计三个参数，级别、回调间隔、回调次数；
/**
* 回调策略
*/
public enum CallbackType {
//等级1，10s执行3次
SECONDS_10(1, 10, 3),
//等级2，30s执行2次
SECONDS_30(2, 30, 2),
//等级3，60s执行2次
MINUTE_1(3, 60, 2),
//等级4，5min执行1次
MINUTE_5(4, 300, 1),
//等级5，30min执行1次
MINUTE_30(5, 30*60, 1),
//等级6，1h执行2次
HOUR_1(6, 60*60, 1),
//等级7，3h执行2次
HOUR_3(7, 60*60*3, 1),
//等级8，6h执行2次
HOUR_6(8, 60*60*6, 1);
//级别
private int level;
//回调间隔时间 秒
private int intervalTime;
//回调次数
private int count;
}3.2 数据传输对象设计
声明抽象父类，便于其他对象调用传输继承。
/**
* 消息对象父类
*/
public abstract class MessageInfo {
//开始时间
private long startTime;
//更新时间
private long updateTime;
//是否回调成功
private boolean isSuccess=false;
//回调次数
private int count=0;
//回调策略
private CallbackType callbackType;
}要传输的对象，继承消息父类；
/**
* 工单回调信息
*/
public class WorkOrderMessage extends MessageInfo {
//车架号
private String vin;
//工单号
private String workorderno;
//工单状态
private Integer status;
//工单原因
private String reason;
//操作用户
private Integer userid;
}3.3 调度线程池的使用
//声明线程池，大小为16
private ScheduledExecutorService pool = Executors.newScheduledThreadPool(16);
...略
while (true){
//从队列获取数据，交给定时器执行
try {
WorkOrderMessage message = MessageQueue.getMessageFromNext();
long excueTime = message.getUpdateTime()+message.getCallbackType().getIntervalTime()* 1000;
long t = excueTime - System.currentTimeMillis();
if (t/1000 < 5) {//5s之内将要执行的数据提交给调度线程池
System.out.println("MessageHandleNext-满足定时器执行条件"+JSONObject.toJSONString(message));
pool.schedule(new Callable() {
@Override
public Boolean call() throws Exception {
remoteCallback(message);
return true;
}
}, t, TimeUnit.MILLISECONDS);
}else {
MessageQueue.putMessageToNext(message);
}
} catch (InterruptedException e) {
System.out.println(e);
}
} 3.4 retrofit2的使用，方便好用。
具体可查看官网相关文档进行了解，用起来还是比较方便的。http://square.github.io/retrofit/
retrofit初始化：
import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;
public class RetrofitHelper {
private static final String HTTP_URL = "http://baidu.com/";
private static Retrofit retrofit;
public static Retrofit instance(){
if (retrofit == null){
retrofit = new Retrofit.Builder()
.baseUrl(HTTP_URL)
.addConverterFactory(GsonConverterFactory.create())
.build();
}
return retrofit;
}
}如果需要修改超时时间，连接时间等可以这样初始话，Retrofit采用OkHttpClient
import okhttp3.OkHttpClient;
import retrofit2.Retrofit;
import retrofit2.converter.gson.GsonConverterFactory;
import java.util.concurrent.TimeUnit;
public class RetrofitHelper {
private static final String HTTP_URL = "http://baidu.com/";
private static Retrofit retrofit;
public static Retrofit instance(){
if (retrofit == null){
retrofit = new Retrofit.Builder()
.baseUrl(HTTP_URL)
.client(new OkHttpClient.Builder()
.connectTimeout(30, TimeUnit.SECONDS)//连接时间
.readTimeout(30, TimeUnit.SECONDS)//读时间
.writeTimeout(30, TimeUnit.SECONDS)//写时间
.build())
.addConverterFactory(GsonConverterFactory.create())
.build();
}
return retrofit;
}
}Retrofit使用通过接口调用，要先声明一个接口；
import com.alibaba.fastjson.JSONObject;
import com.woasis.callbackdemo.bean.WorkOrderMessage;
import retrofit2.Call;
import retrofit2.http.Body;
import retrofit2.http.POST;
public interface WorkOrderMessageInterface {
@POST("/api")
Call updateBatteryInfo(@Body WorkOrderMessage message);
} 接口和实例对象准备好了，接下来就是调用；
private void remoteCallback(WorkOrderMessage message){
//实例接口对象
WorkOrderMessageInterface workOrderMessageInterface = RetrofitHelper.instance().create(WorkOrderMessageInterface.class);
//调用接口方法
Call objectCall = workOrderMessageInterface.updateBatteryInfo(message);
System.out.println("远程调用执行："+new Date());
//异步调用执行
objectCall.enqueue(new Callback() {
@Override
public void onResponse(Call call, Response response) {
System.out.println("MessageHandleNext****调用成功"+Thread.currentThread().getId());
message.setSuccess(true);
System.out.println("MessageHandleNext-回调成功"+JSONObject.toJSONString(message));
}
@Override
public void onFailure(Call call, Throwable throwable) {
System.out.println("MessageHandleNext++++调用失败"+Thread.currentThread().getId());
//失败后再将数据放入队列
try {
//对回调策略初始化
long currentTime = System.currentTimeMillis();
message.setUpdateTime(currentTime);
message.setSuccess(false);
CallbackType callbackType = message.getCallbackType();
//获取等级
int level = CallbackType.getLevel(callbackType);
//获取次数
int count = CallbackType.getCount(callbackType);
//如果等级已经最高，则不再回调
if (CallbackType.HOUR_6.getLevel() == callbackType.getLevel() && count == message.getCount()){
System.out.println("MessageHandleNext-等级最高，不再回调， 线下处理:"+JSONObject.toJSONString(message));
}else {
//看count是否最大，count次数最大则增加level
if (message.getCount()3.5结果实现
关于怎么在Java中按时间梯度异步回调接口就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
文章标题：怎么在Java中按时间梯度异步回调接口
标题路径：http://jkwzsj.com/article/gegejo.html