疯狂Java讲义：使用ServletSocket创建TCP服务器端

使用ServletSocket创建TCP服务器端

从图 中看上去TCP通信的两个通信实体之间并没有服务器端 客户端之分 但那是两个通信实体已经建立虚拟链路之后的示意图 在两个通信实体没有建立虚拟链路之前 必须有一个通信实体先做出 主动姿态 主动接收来自其他通信实体的连接请求

Java中能接受其他通信实体连接请求的类是ServerSocket ServerSocket对象用于监听来自客户端的Socket连接 如果没有连接 它将一直处于等待状态 ServerSocket包含一个监听来自客户端连接请求的方法

Socket accept（） 如果接收到一个客户端Socket的连接请求 该方法将返回一个与客户端Socket对应的Socket（如图 所示每个TCP连接有两个Socket） 否则该方法将一直处于等待状态 线程也被阻塞

为了创建ServerSocket对象 ServerSocket类提供了如下几个构造器

ServerSocket（int port） 用指定的端口port来创建一个ServerSocket 该端口应该是有一个有效的端口整数值 ~

ServerSocket（int port int backlog） 增加一个用来改变连接队列长度的参数backlog

ServerSocket（int port int backlog InetAddress localAddr） 在机器存在多个 IP地址的情况下 允许通过localAddr这个参数来指定将ServerSocket绑定到指定的IP地址

当ServerSocket使用完毕 应使用ServerSocket的close（）方法来关闭该ServerSocket 通常情况下 服务器不应该只接受一个客户端请求 而应该不断地接受来自客户端的所有请求 所以Java程序通常会通过循环 不断地调用ServerSocket的accept（）方法 如下代码片段所示

//创建一个ServerSocket 用于监听客户端Socket的连接请求

ServerSocket ss = new ServerSocket（ ）

//采用循环不断接受来自客户端的请求

while （true）

{

//每当接受到客户端Socket的请求 服务器端也对应产生一个Socket

Socket s = ss accept（）

//下面就可以使用Socket进行通信了

…

}

上面程序中创建ServerSocket没有指定IP地址 则该ServerSocket将会绑定到本机默认的IP地址 程序中使用 作为该ServerSocket的端口号 通常推荐使用 以上的端口 主要是为了避免与其他应用程序的通用端口冲突

       返回目录 疯狂Java讲义

       编辑推荐

       Java程序性能优化 让你的Java程序更快 更稳定

       新手学Java 编程

lishixinzhi/Article/program/Java/hx/201311/27266

服务器监听端口 做个无限循环 接到一个连接就创建一个通道线程，并将通道线程存储到一个list集合中

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

import java.io.BufferedReader

import java.io.IOException

import java.io.InputStreamReader

import java.io.PrintWriter

import java.net.ServerSocket

import java.net.Socket

import java.text.SimpleDateFormat

import java.util.ArrayList

import java.util.Date

import java.util.List

/*

* 4.用socket通讯写出多个客户端和一个服务器端的通讯，

* 要求客户发送数据后能够回显相同的数据（回显功能）（实用TCP方式）。

*/

public class Test4Server {

// 主入口

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

scoketServer()

}

// 开启的tcp8888监听端口

public static void scoketServer() throws IOException {

ServerSocket server = new ServerSocket(8888)

while (true) {

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

Socket socket = server.accept()

System.out.println(socket.getInetAddress().getHostAddress()

+ "连接进入")

new SocketThread(socket).start()

}

}

}

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

class SocketThread extends Thread {

// 所有通道写入流的集合

private static List<PrintWriter>list =new ArrayList<PrintWriter>()

private BufferedReader bufferedReader

private PrintWriter printWriter

public SocketThread(Socket socket) throws IOException {

this.bufferedReader = new BufferedReader(new InputStreamReader(socket

.getInputStream()))

this.printWriter = new PrintWriter(socket.getOutputStream())

list.add(printWriter)

}

@Override

public void run() {

String string = null

while (true) {

try {

// 服务器在通道中读到的信息回显给客服端

string = bufferedReader.readLine()

System.out.println("客服端信息：" + string)

for(PrintWriter printWriter:list ){

printWriter.write("服务器回显：" + string + "\r\n")

printWriter.flush()

}

} catch (IOException e) {

}

}

}

}

客服端代码 可以用在局域网中用多台来连接测试

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

import java.io.BufferedReader

import java.io.IOException

import java.io.InputStreamReader

import java.io.PrintWriter

import java.net.Socket

import java.util.Scanner

public class Test4Client {

public static Object obj = new Object()

// 客服端的主入口

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

socketClient()

}

// 与服务器连通地址本机（127.0.0.1），局域网中其他机器是（服务器在局域网中的ip地址） 端口都是8888

public static void socketClient() throws IOException {

Socket socket = new Socket("127.0.0.1", 8888)

if (socket.isConnected()) {

// 如果连接成功了就开启写和读的进程

new writer(socket).start()

new read(socket).start()

} else {

System.out.println("服务器未开启")

}

}

}

// 写入到通道的线程

class writer extends Thread {

@SuppressWarnings("unused")

private Socket socket

private PrintWriter printWriter

private Scanner scanner = new Scanner(System.in)

private String str = null

public writer(Socket socket) throws IOException {

this.socket = socket

this.printWriter = new PrintWriter(socket.getOutputStream())

}

@Override

public void run() {

scanner.useDelimiter("\r\n")

while (true) {

System.out.print("请输入信息：")

// 产生扫描器的线程阻塞

str = scanner.next()

System.out.println("我说："+str)

printWriter.write(str + "\r\n")

printWriter.flush()

try {

Thread.sleep(200)

} catch (InterruptedException e) {

e.printStackTrace()

}

}

}

}

// 从通道中读取的线程

class read extends Thread {

private Socket socket

private BufferedReader bufferedReader

private String str = null

public read(Socket socket) throws IOException {

this.socket = socket

this.bufferedReader = new BufferedReader(new InputStreamReader(socket

.getInputStream()))

}

@Override

public void run() {

while (true) {

try {

str = bufferedReader.readLine()

System.out.println(str)

} catch (IOException e) {

}

try {

Thread.sleep(200)

} catch (InterruptedException e) {

e.printStackTrace()

}

}

}

}

你服务器accept方法后是不是会得到一个Socket

为这个Socket（是通过这个Socket和客户端的Socket进行沟通）分配一个服务

我是这么用的ServerThread tt=new ServerThread(socket)

class ServerThread

{

private Socket so

public ServerThread(Socket s)

{

this.so=s

}

public void send()

{

}

public void receive()

{

Thread re=new Thread()

{

public void run()

{

}

}

}

}

相当于你用手机拨打人工服务，会给你分配一个客服

为这个Socket分配后，写一个发送方法，和一个接收方法（线程）

然后把ServerThread tt=new ServerThread(socket)中的tt保存到集合中去，要单独给某个发送

就从集合中取出来.send()这个方法应该带个参数，把消息对象传过去就是

---