javasocket调试_JAVA实现SOCKET多客户端通信的案例

一、ServerSocket

1.为了方便调试&＃xff0c;先创建一个界面用于显示客户端连接信息

基于javafx包写的一个简单界面&＃xff01;

javafx.scene.control.TextArea ta &＃61; new javafx.scene.control.TextArea();

&＃64;Override

public void start(Stage primaryStage) throws Exception {

scene &＃61; new Scene(ta,450,200);

primaryStage.setTitle("SocketServer");

primaryStage.setScene(scene);

primaryStage.show();

pStage &＃61; primaryStage;

new Thread(new MyServer()).start(); //创建线程启动Socket服务

}

2.启动Socket服务

public class MyServer implements Runnable{

&＃64;Override

public void run() {

try{

java.net.ServerSocket serverSocket &＃61; new java.net.ServerSocket(8000);

ta.appendText("Server started at " &＃43; new Date()&＃43;"\n");

while(true){

Socket socket &＃61; serverSocket.accept(); //程序会在这里阻塞&＃xff0c;直到等到客户端连接

clientNumber&＃43;&＃43;;

/*

这里就是在界面中输出一些服务器、和连接的客户端信息

*/

Platform.runLater(()->{

ta.appendText("Starting thread for client " &＃43; clientNumber &＃43; " at " &＃43;

new Date() &＃43;"\n");

InetAddress inetAddress &＃61; socket.getInetAddress();

ta.appendText("Client "&＃43;clientNumber &＃43; "&＃39;s host name is" &＃43;inetAddress.getHostName()

&＃43;"\n");

ta.appendText("Client"&＃43;clientNumber &＃43; "&＃39;s IP address is "&＃43; inetAddress.getHostAddress()&＃43;"\n");

});

/*

每有一个客户端连接服务器就创建一个线程&＃xff0c;进行通信处理

*/

new Thread(new HandleServer(socket)).start();

try{

Thread.sleep(100); //多个客户端连续快速连接服务器时&＃xff0c;可能出现问题&＃xff0c;这里设置延时

}catch (InterruptedException e){

e.printStackTrace();

}

}

}catch (IOException e){

e.printStackTrace();

}

}

}

这一段代码主要作用就是循环等待客户端连接服务器&＃xff1a;

Socket socket &＃61; serverSocket.accept();

在写这篇博客时&＃xff0c;突然想知道阻塞的原理就去查了一下。。。。

然而并没有看懂。。这个应该涉及到操作系统层面&＃xff0c;等之后把操作系统搞明白了在来补充吧。

3.服务器处理类HandleServer

class HandleServer implements Runnable {

private Socket socket;

private int name;

private int toClientID;

private DataOutputStream outputStream;

private DataInputStream inputStream;

public HandleServer(Socket socket){

this.socket &＃61; socket;

ServerTools.Tools().add(this);

this.name &＃61; clientNumber;

}

&＃64;Override

public void run() {

try{

inputStream &＃61; new DataInputStream(socket.getInputStream());

outputStream &＃61; new DataOutputStream(socket.getOutputStream());

outputStream.writeUTF("Your ID is:"&＃43;clientNumber);

while (true){

toClientID &＃61; inputStream.readInt();

String messageGET &＃61; inputStream.readUTF();

int err &＃61; ServerTools.Tools().MyWriteUTF(messageGET,toClientID); //MyWriteUTF 是一个自定义方法&＃xff0c;serverTools.Tools()是一个工具类&＃xff0c;一个静态对象。

if (err&＃61;&＃61;0){

outputStream.writeUTF("No have this ID!");

}

Platform.runLater(()->{

ta.appendText(socket.getInetAddress().getHostName()&＃43;" Message received from client:" &＃43; messageGET &＃43;"\n" );

});

System.out.println(clientNumber);

}

}catch (IOException e){

clientNumber--;

System.out.println(clientNumber);

System.err.println("Client is closed!");

}

}

这一块的代码主要就是创建输入输出数据流了

inputStream &＃61; new DataInputStream(socket.getInputStream());

outputStream &＃61; new DataOutputStream(socket.getOutputStream());

4.一些方法方便ServerTools类实现

public void MyWriteUTF(String message){

try {

outputStream.writeUTF(message);

} catch (IOException e) {

ServerTools.Tools().remove(this);

e.printStackTrace();

}

}

public int getName() {

return name;

}

二、ServerTools

1.实现指定服务器ID输出信息的工具

public class ServerTools {

private static final ServerTools servertools &＃61; new ServerTools();

public static ServerTools Tools(){

return servertools;

}

Vector vector &＃61; new Vector();

public void add(MyServerSocket.HandleServer cs){

vector.add(cs);

}

public void remove(MyServerSocket.HandleServer cs){

vector.remove(cs);

}

public int MyWriteUTF(String message,int target) {

for (int i &＃61; 0; i <&＃61; target; i&＃43;&＃43;){

try {

if (vector.get(i).getName() &＃61;&＃61; target) {

MyServerSocket.HandleServer MSSHC &＃61; vector.get(i);

MSSHC.MyWriteUTF(message);

return 1;

}

}catch (ArrayIndexOutOfBoundsException e){

e.printStackTrace();

return 0;

}

}

return 0;

}

}

vector用于保存客户端连接信息

一个粗糙的处理方式&＃xff0c;逻辑上缺陷还很严重&＃xff0c;主要我好像没找到这样的框架&＃xff1f;&＃xff1f;&＃xff1f;

缺陷&＃xff1a;因为服务器要返回客户端的ID让客户端将ID显示到交互界面&＃xff0c;所以存在情况客户端多次连接断开后会使返回的ID出现重复

三、ClientSocket

1.同样的先建一个简单的界面用于输出信息和显示信息

第一个编辑框就是 输入要发送指定客户端的ID 例如&＃xff1a;1 或 2 这样的&＃xff1f;&＃xff1f;&＃xff1f;

第二个编辑框就是 输入你要发送的信息了&＃xff0c;很清楚

下面的就是显示框&＃xff0c;嗯&＃xff01;

public class MyClientSocket extends Application {

private Socket socket;

private DataOutputStream toServer &＃61; null;

private DataInputStream fromServer &＃61; null;

private String ID;

private int targetID &＃61; 0;

private TextArea ta;

&＃64;Override

public void start(Stage primaryStage) throws Exception {

BorderPane paneForTextField &＃61; new BorderPane();

paneForTextField.setPadding(new Insets(5,5,5,5));

paneForTextField.setStyle("-fx-border-color: green");

paneForTextField.setLeft(new Label("Enter a Message:"));

TextField tf &＃61; new TextField();

tf.setAlignment(Pos.BOTTOM_RIGHT);

paneForTextField.setCenter(tf);

BorderPane ID_lable &＃61; new BorderPane();

ID_lable.setPadding(new Insets(5,5,5,5));

ID_lable.setStyle("-fx-border-color: green");

ID_lable.setLeft(new Label("Enter a ID for send message:"));

TextField getId &＃61; new TextField();

getId.setAlignment(Pos.BOTTOM_RIGHT);

ID_lable.setCenter(getId);

paneForTextField.setTop(ID_lable);

BorderPane mainPane &＃61; new BorderPane();

ta &＃61; new TextArea();

mainPane.setCenter(new ScrollPane(ta));

mainPane.setTop(paneForTextField);

Scene scene &＃61; new Scene(mainPane,450,200);

primaryStage.setTitle("SocketClient");

primaryStage.setScene(scene);

primaryStage.show();

tf.setOnAction(new EventHandler() {

&＃64;Override

public void handle(ActionEvent event) {

targetID &＃61; Integer.parseInt(getId.getText().trim());

if (targetID > 0 || targetID!&＃61;Integer.parseInt(ID));

else return;

try {

String putMessage &＃61; tf.getText().trim();

toServer.writeInt(targetID);

toServer.writeUTF(putMessage);

toServer.flush();

ta.appendText("PUT message is :"&＃43; putMessage &＃43;"\n");

tf.setText("");

}catch (IOException ex ){

System.err.println(ex);

}

}

});

try{

socket &＃61; new Socket("localhost",8000);

fromServer &＃61; new DataInputStream(socket.getInputStream());

toServer &＃61; new DataOutputStream(socket.getOutputStream());

ID &＃61; fromServer.readUTF();

paneForTextField.setRight(new Label("Your ID is:"&＃43;ID));

new Thread(new getMessage(socket,fromServer)).start();

}catch (IOException ex){

ta.appendText(ex.toString() &＃43;"\n");

}

}

}

一样的要new一个Socket 去连接服务器&＃xff0c;socket()&＃xff0c;括号里的就是服务器的IP&＃xff0c;和程序的端口号了&＃xff0c;这种基于tcp协议的好像都是一个样&＃xff1f;&＃xff1f;&＃xff1f;

2.创建一个线程用于循环获取信息并显示

class getMessage implements Runnable{

private Socket socket;

private DataInputStream formServer;

public getMessage(Socket socket,DataInputStream formServer){

this.socket &＃61; socket;

this.formServer &＃61; formServer;

}

&＃64;Override

public void run() {

try {

while (true) {

String Message &＃61; formServer.readUTF();

try{

Thread.sleep(100);

}catch (InterruptedException e) {

e.printStackTrace();

}

ta.appendText("GET message from server is:" &＃43; Message &＃43; "\n");

}

}catch (IOException e){

System.err.println(e);

}

}

}

很简单了&＃xff0c;依旧是输入输出数据流&＃xff0c;然后循环等待信息并输出。

3.新建一个TestClient类 这个类 和ClientSocket 一模一样 就是拿来测试的

四、总结

java写socket 是真的简单&＃xff01;&＃xff01;&＃xff01;^_ ^!

以上这篇JAVA实现SOCKET多客户端通信的案例就是小编分享给大家的全部内容了&＃xff0c;希望能给大家一个参考&＃xff0c;也希望大家多多支持脚本之家。