JAVA如何实现基于Socket的多线程通信

这篇文章主要介绍了JAVA如何实现基于Socket的多线程通信，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

创新互联公司是一家专业提供盐边企业网站建设,专注与网站制作、成都做网站、H5建站、小程序制作等业务。10年已为盐边众多企业、政府机构等服务。创新互联专业的建站公司优惠进行中。

代码简介

代码思想：

实现"服务端-客户端"之间的通信需要解决两点问题

(1)，如何实现通信

(2)，通信中如何避免单线程先接收后发送(或先发送后接收)的问题;

解决方案：

(1)，实现通信：使用ServerSocket监听指定端口后，Socket进行连接;然后客户端与服务端都获取Socket对象的输入输出流存入PrintWrite后不断刷新，即可实现通信;

(2)，弥补单线程缺陷：创建消息接收类和消息发送类分别继承Thread;然后通过开启两个线程完避免单线程必须先接收后发送(或先发送后接收)的问题;

服务端

package x_Socket;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class x_Server{

/** 声明全局对象,让x_Server的内部类可以共同调用这些对象 **/

static ServerSocket serverSocket = null;//声明静态全局的socket类对象;让x_Server的静态方法可以直接调用该对象;

static Socket socket = null; //声明静态全局的socket类对象;让x_Server的静态方法可以直接调用该对象;

BufferedReader buffSend = null; //信息发送数据流

BufferedReader buffReciever = null; //信息接收数据流

PrintWriter printWriter = null; //数据读写数据流

/** 主函数入口 **/

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

serverSocket = new ServerSocket(5556); //通过Socket的构造函数,监听的5556端口(即等待socket对象向该端口请求连接)

socket = serverSocket.accept(); //如果有socket的对象请求连接了5556端口，则serverSocket的accept返回一个socket对象;

System.out.println("有用户成功连接客户端");

Thread xsend = new Thread(new x_Server().new x_Send()); //通过Thread类的构造函数，创建一个x_Send类的线程对象

Thread xreciver = new Thread(new x_Server().new x_Receiver()); //通过外部类对象去实例化内部类，再通过Thread的构造函数，创建内部类x_Reciever的线程二对象;

xsend.start(); //启动x_Send的线程，让发送与接收数据可以同时进行

xreciver.start(); //启动x_Receiver的线程，让发送与接收数据可以同时进行

}

/** 用于服务端发送信息的x_Send类(线程一) **/

class x_Send extends Thread{

public void run(){ //继承Thread类，必须重写run()方法

try {

buffSend = new BufferedReader(new InputStreamReader(System.in));//获取从控制台输入数据的对象buffSend

printWriter = new PrintWriter(socket.getOutputStream()); //通过PrintWriter类的构造方法，获取向客户端发送信息的输出流对象

String msg = null; //msg:存储服务端发送的信息

do{

msg = buffSend.readLine(); //获得从控制台输入一行的信息

printWriter.println(msg); //将msg传到向服务端发送信息的输出流对象

printWriter.flush(); //刷新输入输出流，客户端端可以立刻收到输入输出流的更新信息

}while(!msg.equals("end")); //客户输入"end"表示结束通信

socket.close(); //关闭端口5556的连接

serverSocket.close(); //不再监听端口5556(即不再接收来自该端口的连接)

} catch (IOException e) {

System.out.println("客户端连接已断开");

e.printStackTrace();

}

}

}

/** 用于服务端接收信息的x_Reciever类(线程二) **/

class x_Receiver extends Thread{

public void run(){ //继承Thread类，必须重写run()方法

try {

buffReciever = new BufferedReader(new InputStreamReader(socket.getInputStream())); //获取从socket输入(客户端传输过来)数据的输入流对象

while(true){

System.out.println("接收客户端消息："+buffReciever.readLine()); //输出客户端传输过来的信息

}

} catch (IOException e) {

System.out.println("客户端连接已断开：\n");

e.printStackTrace();

}

}

}

}

客户端

package x_Socket;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

import java.net.UnknownHostException;

public class x_Client {

/** 声明全局对象,让x_Client的内部类可以共同调用这些对象 **/

static Socket socket = null; //声明静态全局的socket类对象;让x_Client的静态方法可以直接调用该对象;

BufferedReader buffSend = null; //信息发送数据流

BufferedReader buffReciever = null; //信息接收数据流

PrintWriter printWriter = null; //数据读写数据流

/** 主函数入口 **/

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

socket =new Socket("127.0.0.1",5556); //通过Socket的构造函数，连接本地ip的5556端口

System.out.println("连接服务端信息如下：\nip:127,0.0.1 port:5556");

Thread xsend = new Thread(new x_Client().new x_SendMsg()); //通过Thread类的构造函数，创建一个x_SendMsg类的线程对象

Thread xreciver = new Thread(new x_Client().new x_RecieverMsg()); //通过外部类对象去实例化内部类，再通过Thread的构造函数，创建内部类x_RecieverMsg的线程二对象;

xsend.start(); //启动x_SendMsg的线程;

xreciver.start(); //启动x_RecieverMsg的线程;两个让发送与接收数据可以同时进行

}

/** 用于客户端发送信息的x_SendMsg类(线程一)**/

class x_SendMsg extends Thread{

public void run(){ //继承Thread类，必须重写run()方法

try {

buffSend = new BufferedReader(new InputStreamReader(System.in));//获取从控制台输入数据的对象buffSend

printWriter = new PrintWriter(socket.getOutputStream()); //通过PrintWriter类的构造方法，获取向服务端发送信息的输出流对象

String msg = null; //msg:存储客户端发送的信息

do{

msg = buffSend.readLine(); //获得从控制台输入一行的信息

printWriter.println(msg); //将msg传到向服务端发送信息的输出流对象

printWriter.flush(); //刷新输入输出流，服务端可以立刻收到输入输出流的更新信息

}while(!msg.equals("end")); //客户输入"end"表示结束通信

socket.close(); //关闭端口5556的连接

} catch (IOException e) {

System.out.println("服务端端口已关闭"); //异常提示信息显示

e.printStackTrace();　郑州祛胎记医院哪家好 http://www.zykeda120.com/

}

}

}

/** 用于客户端接收信息的x_RecieverMsg类(线程二) **/

class x_RecieverMsg extends Thread{

public void run(){ //继承Thread类，必须重写run()方法

try {

buffReciever = new BufferedReader(new InputStreamReader(socket.getInputStream())); //获取从socket输入(服务端传输过来)数据的输入流对象

while(true){

System.out.println("收到服务端消息："+buffReciever.readLine()); //输出服务端传输过来的信息

}

} catch (IOException e) {

System.out.println("服务端端口已关闭"); //异常提示信息显示

e.printStackTrace();

}

}

感谢你能够认真阅读完这篇文章，希望小编分享的“JAVA如何实现基于Socket的多线程通信”这篇文章对大家有帮助，同时也希望大家多多支持创新互联，关注创新互联行业资讯频道，更多相关知识等着你来学习!