FilesExpand file tree

 master

/

Server.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

69 lines (61 loc) · 1.81 KB

 master

/

Server.java

Copy path

Top

File metadata and controls

• Code
• Blame

69 lines (61 loc) · 1.81 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

package Questions;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.ServerSocket;

import java.net.Socket;

import java.text.SimpleDateFormat;

import java.util.Date;

public class Server {

// 主入口

public static void main(String[] args) throws IOException {

scoketServer();

}

// 开启的tcp8888监听端口

private static void scoketServer() throws IOException {

ServerSocket server = new ServerSocket(8888);

while (true) {

// 未连通前线程阻塞，连通后开启一个socket通道线程后继续监听8888端口

Socket socket = server.accept();

new SocketThread(socket).start();

}

}

}

// 一个服务器端口中监听多个客服端通道线程

class SocketThread extends Thread {

private Socket socket = null;

private BufferedReader bufferedReader = null;

private String context = "";

private long span = 0;

private int threadNo = 0;

public SocketThread(Socket socket) throws IOException {

this.socket = socket;

this.bufferedReader = new BufferedReader(new InputStreamReader(socket

.getInputStream()));

}

@Override

public void run() {

String line = null;

String addr = socket.getInetAddress().getHostAddress();

SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

try {

line = bufferedReader.readLine();

String[] strs = line.split(" ");

this.threadNo = Integer.parseInt(strs[1]);

this.context = strs[2];

this.span = Long.parseLong(strs[3]);

System.out.println(threadNo + ":[" + addr + "]");

} catch (IOException e) {

e.printStackTrace();

}

while (true) {

String now = df.format(new Date());

System.out.println(now + " " + threadNo + " " + context);

try {

Thread.sleep(1000 * span);

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}