0.前言
JavaFX作為JAVA客戶端GUI框架戚炫，在使用JavaFX作為前端開(kāi)發(fā)的時(shí)候猜旬，如果使用了前后端分離的方式開(kāi)發(fā)桩砰，脫離了JDBC阶捆，那網(wǎng)絡(luò)請(qǐng)求必不可少凌节，下面選用了比較火熱的OKHTTP，JAVA還有很多其他網(wǎng)絡(luò)請(qǐng)求框架洒试，但是感覺(jué)OKHTTP封裝起來(lái)比較靈活倍奢。
1.Gradle導(dǎo)包
因?yàn)楣こ逃玫腉radle管理工具，需要jar包的可以自己到maven官網(wǎng)下載垒棋。
compile group: 'com.squareup.okhttp3', name: 'okhttp', version: '3.10.0'
compile group: 'com.squareup.okio', name: 'okio', version: '1.14.0'
compile group: 'com.google.code.gson', name: 'gson', version: '2.8.4'
2.建立接口回調(diào)類(lèi)HttpBack
接口回調(diào)類(lèi)用于自定義回調(diào)卒煞，在建立HttpService 時(shí)會(huì)用到
package bccsclient.api;
import okhttp3.Call;
public interface HttpBack {
void onsucess(Call call,String response);
void onfail(Call call, String e);
}
3.封裝類(lèi)HttpService
OKHTTP設(shè)置十分靈活大家可以根據(jù)自己需求，修改封裝類(lèi)HttpService
package bccsclient.api;
import bccsclient.util.DialogUtil;
import bccsclient.util.JsonUtil;
import com.google.gson.Gson;
import javafx.application.Platform;
import javafx.scene.control.Alert;
import okhttp3.*;
import java.io.IOException;
import java.util.Map;
import java.util.prefs.Preferences;
/**
* @Author bb
* @Create 2018/5/18
* @Description 網(wǎng)絡(luò)請(qǐng)求封裝類(lèi)
*/
public class HttpService {
private static final MediaType JSON
= MediaType.parse("application/json; charset=utf-8");
private static String authorizationHead = "";
private volatile static HttpService INSTANCE;
private volatile static Gson gson;
private volatile static OkHttpClient mOkHttpClient;
private static String baseurl;
private HttpService() {
mOkHttpClient = new OkHttpClient();
Preferences preferences = Preferences.userRoot().node(Constant.Preferences_Node);
baseurl = preferences.get("baseurl", "");
authorizationHead = preferences.get("authorizationHead", "");
}
public static HttpService getInstance() {
if (INSTANCE == null) {
synchronized (HttpService.class) {
if (INSTANCE == null) {
INSTANCE = new HttpService();
}
}
}
return INSTANCE;
}
/**
* 異步get請(qǐng)求
*
* @param uri
* @param map
* @param callback
*/
public static void httpGet(String uri, Map<String, String> map, HttpBack callback) {
if (map.size() != 0) {
uri = uri + "?";
for (String in : map.keySet()) {
String str = map.get(in);
uri = uri + in + "=" + str + "&";
}
uri = uri.substring(0, uri.length() - 1);
}
Request request = new Request.Builder()
.addHeader("authorization", authorizationHead)
.url(baseurl + uri)
.get().build();
Call call = mOkHttpClient.newCall(request);
callListener(call, callback);
}
/**
* 異步Post鍵值對(duì)請(qǐng)求
*
* @param uri
* @param map
* @param callback
*/
public static void httpPostMap(String uri, Map<String, String> map, HttpBack callback) {
FormBody.Builder builder = new FormBody.Builder();
for (String in : map.keySet()) {
builder.add(in, map.get(in));
}
RequestBody body = builder.build();
Request request = new Request.Builder()
.addHeader("authorization", authorizationHead)
.url(baseurl + uri)
.post(body).build();
Call call = mOkHttpClient.newCall(request);
callListener(call, callback);
}
/**
* 異步Post Bean請(qǐng)求
*
* @param uri
* @param Bean
* @param callback
* @param <T>
*/
public static <T> void httpPostBean(String uri, T Bean, HttpBack callback) {
RequestBody body = RequestBody.create(JSON, JsonUtil.bean2Json(Bean));
Request request = new Request.Builder()
.addHeader("authorization", authorizationHead)
.url(baseurl + uri)
.post(body).build();
Call call = mOkHttpClient.newCall(request);
callListener(call, callback);
}
public static void callListener(Call call, HttpBack httpBack) {
call.enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) {
Platform.runLater(() -> {
httpBack.onfail(call, e);
DialogUtil.createExceptionDialog("警告", "網(wǎng)絡(luò)請(qǐng)求異常", e);
});
}
@Override
public void onResponse(Call call, Response response) throws IOException {
if (response.isSuccessful()) {
try {
Object onsucess = httpBack.onsucess(call, response.body().string());
Platform.runLater(() -> {
httpBack.onsucessView(onsucess);
});
} catch (IOException e) {
e.printStackTrace();
}
} else {
Platform.runLater(() -> {
httpBack.onfail(call, new Exception(response.message()));
DialogUtil.createAlert(Alert.AlertType.WARNING, "網(wǎng)絡(luò)請(qǐng)求失敗" + response.code());
});
}
}
});
}
}
4.使用HttpService
//http示例1--post
private void httppost() {
HttpService.getInstance().httpPostBean("auth", new AuthBean("dengxin", "1"), new HttpBack() {
@Override
public Object onsucess(Call call, String response) {
System.out.println(response);
return response;
}
@Override
public void onsucessView(Object object) {
TextArea.setText("請(qǐng)求成功：" + (String) object);
}
@Override
public void onfail(Call call, Exception e) {
System.out.println("失敗");
TextArea.setText("請(qǐng)求失數鸺堋：" + e);
}
});
}
//http示例2--get請(qǐng)求-帶參數(shù)
private void httpget3() {
Map<String, String> map = new HashMap();
map.put("projid", "P0001");
HttpService.getInstance().httpGet("main/tops", map, new HttpBack() {
@Override
public Object onsucess(Call call, String response) {
System.out.println(response);
JsonUtil.json2JSONArray(response);
return JsonUtil.json2JSONArray(response);
}
@Override
public void onsucessView(Object object) {
TextArea.setText("請(qǐng)求成功：" + object);
}
@Override
public void onfail(Call call, Exception e) {
System.out.println("失敗");
TextArea.setText("請(qǐng)求失斉显！：" + e);
}
});
}