Repository navigation
Expand file tree
/
Copy pathMySocket_Client.java
More file actions
78 lines (72 loc) · 2.16 KB
/
Copy pathMySocket_Client.java
File metadata and controls
78 lines (72 loc) · 2.16 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
package Java.Zone.Socket;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import Java.Zone.Setting.MyJava_Preferences;
/**
* 已经测试 OK 例子说明在 class旁边Client说明
* @author zone
*
*/
public abstract class MySocket_Client {
private static Socket server;
/**
*
* @param host 要连接的服务端IP地址 例如：String host = "192.168.60.111";
* @param port 端口号
*/
public MySocket_Client(String host, int port) {
// TODO Auto-generated constructor stub
MyJava_Preferences.op();
try {
server = new Socket(host, port);
} catch (UnknownHostException e) {
e.printStackTrace();
System.out.println("UnknownHostException！！！");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println("IOException!!!");
}
MyJava_Preferences.InnerOp();
init();
MyJava_Preferences.InnerEd();
MyJava_Preferences.ed();
}
private void init() {
MyJava_Preferences.op();
BufferedInputStream br_in = null;
BufferedOutputStream br_out = null;
try {
br_in = new BufferedInputStream(server.getInputStream());
br_out =new BufferedOutputStream(server.getOutputStream()) ;
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println("server获取流发生IOException！！！");
}
MyJava_Preferences.InnerOp();
sendOrRead(br_in, br_out);
MyJava_Preferences.InnerEd();
try {
br_in.close();
br_out.close();
server.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println("流与客户端关闭发生IOException！！！");
}
MyJava_Preferences.ed();
}
/**
* 在这里写 读写逻辑就行了
* @param br_in service（服务器）提供给你的输入流 已经包装好了 BufferedInputStream
* @param br_out service（服务器）提供给你的输出流 已经包装好了 BufferedOutputStream
*/
public abstract void sendOrRead(BufferedInputStream br_in, BufferedOutputStream br_out);
}