多線程調(diào)用第三方接口

? ?

? ? ? ?private List<String> getUpdateDataList(List<String> phoneList) {

// 創(chuàng)建線程池,這里創(chuàng)建了20個(gè)

ExecutorService executorService = Executors.newFixedThreadPool(20);

// 保存任務(wù)的返回結(jié)果

List<Future<String>> futureList = new ArrayList<>();

// 分配任務(wù)

for (String loopStr : phoneList) {

// 啟動(dòng)多線程返回號(hào)碼的城市，有返回值使用submit()，并且多線程實(shí)現(xiàn)callable接口

Future<String> future = executorService

.submit(new UpdateCityThreadJob<String>(loopStr));

futureList.add(future);

}

// 關(guān)閉線程池

executorService.shutdown();

// 保存城市

List<String> collection = new ArrayList<>();

// 取出任務(wù)中的參數(shù)

for (Future<String> future : futureList) {

try {

// 取出任務(wù)中的結(jié)果

String city = future.get();

collection.add(city);

} catch (Exception e) {

throw new AppException(HttpStatus.INTERNAL_SERVER_ERROR);

}

}

return collection;

}

public class UpdateCityThreadJob<V> implements Callable<String> {

? ? ? ? // 電話號(hào)碼

private String phoneNumber;

public UpdateCityThreadJob(String phoneNumber) {

this.phoneNumber = phoneNumber;

}

/**

* @param phoneNumber 電話號(hào)碼

* @return 城市

* @Description 獲取 電話號(hào)碼歸屬地郵政信息

*/

private String getCityRepeat(String phoneNumber) {

String city = "";

try {

city = getCity(phoneNumber);

} catch (Exception e) {

// 請(qǐng)求失敗，重試五次，（防止網(wǎng)絡(luò)原因?qū)е抡?qǐng)求失?。?/p>

for (int i = 0; i < 5; i++) {

try {

city = getCity(phoneNumber);

} catch (Exception e1) {

continue;

}

}

}

return city;

}

/**

*?

* @Description 獲取城市

* @param phoneNumber 電話號(hào)碼

* @return 城市

* @throws Exception

*/

private String getCity(String phoneNumber) throws Exception {

// 請(qǐng)求第三方接口判斷號(hào)碼歸屬地

String result = HttpClient

.doGet("http://apis.juhe.cn/mobile/get?phone=" + phoneNumber + "&dtype=xml&key=" + Constants.API_KEY);

return result;

}

@Override

public String call() throws Exception {

synchronized (phoneNumber) {

? ? ? ? ? ? ? ? ? ? ? ??

// 獲取城市

String city = getCityRepeat(phoneNumber);

return city;

}

}

}