java连接tcp服务器_java实现tcp通信

文章目录：

• 1、用java做一个TCP服务器怎么样
• 2、如何实现java和tcp的连接
• 3、怎么用java写一个针对各种不同请求的TCP服务端
• 4、java 的 tcp 建立客户端和服务器的连接问题
• 5、怎么用Java实现使用TCP协议实现文件传输程序

用java做一个TCP服务器怎么样

想要用java做一个TCP服务器，就可以使用java网络编程中的java Socket！

服务器的socket是ServerSocket这个类，他的构造方法是：

ServerSocket ss=new ServerSocket(9999);//在端口9999监听

ss.accpect();//静静等待客户端连接！

如何实现java和tcp的连接

TCP: ServerSocket Socket---去远标教育学一下JAVA网络编程吧，很简单，一个TCP和UDP

怎么用java写一个针对各种不同请求的TCP服务端

服务器监听端口 做个无限循环 接到一个连接就创建一个通道线程，并将通道线程存储到一个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 ListPrintWriter list =new ArrayListPrintWriter();

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();

}

}

}

}

java 的 tcp 建立客户端和服务器的连接问题

0.0.0.0表示监听所有IP，在有公网IP的情况下，云服务器上一般这么填写

怎么用Java实现使用TCP协议实现文件传输程序

服务端监听：ServerSocket server=new ServerSocket(port);//port：绑定的端口号

Socket client=server.accept();//监听端口，一旦取得连接则获得客户端的socket连接对象client

客户端： Socket s=new Socket(ip,port);//要连接的服务器的ip以及端口号

如果正常连接上之后，socket的对象可以获得InputStream和OutputStreame，然后就可以进行通信了

完成通信之后，执行socket对象的close（）方法关闭连接，完成一次完整的socket连接