package com.ots.project.tool.report.reportCalculation.socket;
|
import com.alibaba.fastjson.JSON;
|
import com.ots.project.tool.report.reportCalculation.request.HolderInfo;
|
import com.ots.project.tool.report.reportCalculation.request.MaqRequest;
|
import com.ots.project.tool.report.reportCalculation.response.ReportAPIResult;
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.io.PrintWriter;
|
import java.net.InetAddress;
|
import java.net.Socket;
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.Map;
|
import static com.ots.project.tool.report.reportCalculation.request.CalculationTypeEnum.MAQ;
|
import static com.ots.project.tool.report.reportCalculation.request.ReportTypeEnum.firstPath;
|
public class ClientSocket {
|
public static void main(String[] args) throws Exception {
|
|
String readline = null;
|
String inTemp = null;
|
String turnLine = "\n";
|
final String client = "Client:";
|
final String server = "Server:";
|
int port = 9123;
|
byte ipAddressTemp[] = {127, 0, 0, 1};
|
InetAddress ipAddress = InetAddress.getByAddress(ipAddressTemp);
|
|
Socket socket = new Socket(ipAddress, port);
|
|
BufferedReader systemIn = new BufferedReader(new InputStreamReader(System.in));
|
BufferedReader socketIn = new BufferedReader(new InputStreamReader(socket.getInputStream()));
|
PrintWriter socketOut = new PrintWriter(socket.getOutputStream());
|
while (readline != "bye") {
|
System.out.println(client);
|
readline = systemIn.readLine();
|
|
Map data = new HashMap();
|
String topics = "MAQ0001,MAQ0002,MAQ0003,MAQ0006,MAQ0009,MAQ0013,MAQ0020,MAQ0041,MAQ0048,MAQ0088,MAQ0094,MAQ0098,MAQ0112,MAQ0117,MAQ0133,MAQ0145,MAQ0163,MAQ0172,MAQ0174,MAQ0175,MAQ0183,MAQ0194,MAQ0203,MAQ0209,MAQ0212,MAQ0224,MAQ0232,MAQ0233,MAQ0235,MAQ0236,MAQ0241,MAQ0244,MAQ0249,MAQ0250,MAQ0251,MAQ0252";
|
String[] split = topics.split(",");
|
Arrays.asList(split).stream().forEach(item -> {
|
data.put(item, "5");
|
});
|
HolderInfo info = new HolderInfo();
|
info.setAccessCode("abdke12315234");
|
info.setFullName("Bill Li");
|
info.setCalculationType(MAQ);
|
MaqRequest request = new MaqRequest();
|
request.setInfo(info);
|
request.setType(firstPath);
|
request.setData(data);
|
String json = JSON.toJSONString(request);
|
System.out.println(json);
|
socketOut.println(json);
|
socketOut.flush();
|
inTemp = socketIn.readLine();
|
ReportAPIResult reportAPIResult = JSON.parseObject(inTemp, ReportAPIResult.class);
|
System.out.println(reportAPIResult);
|
System.out.println(server + turnLine + inTemp);
|
}
|
systemIn.close();
|
socketIn.close();
|
socketOut.close();
|
socket.close();
|
}
|
}
|
