java实现tcp服务器（单线程、多线程）、客户端
服务器端接收客户申请，响应时间戳和用户源字符串。
客户端使用控制台作为输入输出流
tcp服务器端代码
packagecom.lp.app.net;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;
//tcp服务器，单线程和多线程
public class TCPServer{
public static void main(String[] args) { moreserver(1234);}//读取输入文本，返回响应文本（二级制，对象）public static void server(int port) { try { //创建一个serversocket ServerSocket mysocket=new ServerSocket(port); //等待监听是否有客户端连接 Socket sk = mysocket.accept(); //接收文本信息 BufferedReader in =new BufferedReader(new InputStreamReader(sk.getInputStream())); String data =in.readLine(); System.out.println("客户端消息："+data);复制代码
// //接收二进制字节流// DataInputStream dis =new DataInputStream(new BufferedInputStream(sk.getInputStream()));// byte[] enter =new byte[dis.available()];// dis.read(enter);//
// //接收对象信息// ObjectInput ois =new ObjectInputStream(new BufferedInputStream(sk.getInputStream()));// Object object=ois.readObject();
//输出文本 PrintWriter out =new PrintWriter(new BufferedWriter(new OutputStreamWriter(sk.getOutputStream())),true); out.println(new Date().toString()+":"+data); //服务器返回时间和客户发送来的消息 out.close();复制代码
// //输出二进制// DataOutputStream dos=new DataOutputStream(sk.getOutputStream());// byte[] back="luanpeng".getBytes();// dos.write(back);//
// //输出对象// ObjectOutputStream oos=new ObjectOutputStream(sk.getOutputStream());// oos.writeObject(new Date()); //返回一个时间对象// oos.close();
} catch (Exception e) { // TODO: handle exception }}//多线程服务器public static void moreserver(int port){ try { System.out.println("服务器启动..............."); ServerSocket server=new ServerSocket(port); while(true) { //阻塞，直到有客户连接 Socket sk=server.accept(); //启动服务线程 new ServerThread(sk).start(); } } catch (Exception e) { e.printStackTrace(); }}复制代码
}
//使用线程为多个客户端服务
class ServerThread extends Thread
{
private Socket sk;
ServerThread(Socket sk)
{
this.sk=sk;
}
//线程运行实体
public void run() {
BufferedReader in=null;
PrintWriter out=null;
try {
InputStreamReader isr;
isr=new InputStreamReader(sk.getInputStream());
in=new BufferedReader(isr);
out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(sk.getOutputStream())),true);
while(true)
{
//接收来自客户端的请求，根据不同的命令返回不同的信息
String cmd=in.readLine();
System.out.println(cmd);
if (cmd==null) {
break;
}
out.println(new Date().toString()+":"+cmd); //服务器返回时间和客户发送来的消息
}
} catch (Exception e) {
e.printStackTrace();
}
finally{
try {
if (in!=null) {
in.close();
}
if (out!=null) {
out.close();
}
if (sk!=null) {
sk.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
}
}
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
tcp客户端代码
packagecom.lp.app.net;
importjava.io.;importjava.net.;
//客户端
public class TCPClient {
public static void main(String [] args) throws IOException { connect("192.168.8.102", 1234);}//远程连接public static void connect(String host,int port){ try { System.out.println("客户端启动..............."); Socket sock = new Socket(host, port); // 创建一个写线程 new TelnetWriter(sock.getOutputStream()).start(); // 创建一个读线程 new TelnetReader(sock.getInputStream()).start(); } catch (Exception e) { // TODO: handle exception }}复制代码
}
//从控制台读取用户输入命令 线程类
class TelnetWriter extends Thread {
private PrintStream out;
public TelnetWriter(OutputStream out) { this.out = new PrintStream(out);}public void run() { try { // 包装控制台输入流 BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); // 反复将控制台输入写到Telnet服务程序 while (true) out.println(in.readLine()); } catch (IOException exc) { exc.printStackTrace(); }}复制代码
}
//将响应数据打印到控制台 线程类
class TelnetReader extends Thread {
private InputStreamReader in;
public TelnetReader(InputStream in) { this.in = new InputStreamReader(in);}public void run() { try { // 反复将Telnet服务程序的反馈信息显示在控制台屏幕上 while (true) { // 从Telnet服务程序读取数据 int b = in.read(); if (b == -1) System.exit(0); // 将数据显示在控制台屏幕上 System.out.print((char) b); } } catch (IOException exc) { exc.printStackTrace(); }}复制代码
}
如果你想学好JAVA这门技术，也想在IT行业拿高薪，可以参加我们的训练营课程，选择最适合自己的课程学习，技术大牛亲授，8个月后，进入名企拿高薪。我们的课程内容有：Java工程化、高性能及分布式、高性能、深入浅出。高架构。性能调优、Spring，MyBatis，Netty源码分析和大数据等多个知识点。如果你想拿高薪的，想学习的，想就业前景好的，想跟别人竞争能取得优势的，想进阿里面试但担心面试不过的，你都可以来，q群号为：180705916 进群免费领取学习资料。
作者：高级java架构师
链接：https://juejin.im/post/5ba35b255188256baa21cc7b
来源：掘金
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。
