Comment utiliser le socket Java pour implémenter le chat LAN

Le code est très simple et divisé en deux classes, une classe serveur et un client Lors de l'exécution, deux threads sont démarrés respectivement, l'un est responsable de la réception et l'autre est responsable de l'envoi.

Le processus global est que deux machines démarrent le programme séparément, l'une choisit de se connecter activement et l'autre choisit d'accepter passivement, ce qui peut obtenir un effet de discussion de type QQ et deux personnes peuvent envoyer des messages en même temps.

Veuillez noter que ne démarrez pas les deux sur le même ordinateur en même temps. Cela entraînerait que les adresses IP du serveur et du client soient les mêmes, ce qui pourrait faire en sorte que les messages que vous envoyez soient reçus par vous-même. ordinateurs ou machines virtuelles.

Serveur :

package com.server;
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
 
import com.client.RunClient;
 
public class RunServer {
    public static Socket socket=null;
    /**
     * 建立服务器被动连接
     * @throws IOException
     */
    public void startServer() throws IOException {
        //服务器接收数据
        ServerSocket serverSocekt=new ServerSocket(8888);
        System.out.println("服务器启动，等待连接...");
        //创建客户端线程
        RunClient rc=new RunClient();
        Thread rct=new Thread(rc);
        rct.start();
        
        
        //阻塞线程 监听端口建立socket会话
        RunServer.socket=serverSocekt.accept();
        
        
        //获取输入留
        InputStream is=socket.getInputStream();
        //将字节输入流转换成字符输入流
        InputStreamReader isr=new InputStreamReader(is);
        //将字符输入流装入带缓冲的输入流中
        BufferedReader br=new BufferedReader(isr);
        
        String str=null;
        while((str=br.readLine())!=null){
            System.out.print("输出信息："+str);
        }
        socket.shutdownInput();
        serverSocekt.close();
    }
}

Client :

package com.client;
 
import java.io.BufferedWriter;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
 
import com.server.RunServer;
 
public class RunClient implements Runnable {
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        Scanner input = new Scanner(System.in);
        System.out.println("1、主动连接\n2、被动等待");
        String sign=input.next();
        switch (sign) {
        case "1":
            try {
                System.out.println("输入服务器IP：");
                startClient(input.next());
            } catch (Exception e) {
                e.printStackTrace();
            }
            break;
        case "2":
            try {
                startClient();
            } catch (Exception e) {
                e.printStackTrace();
            }
            break;
            
        default:
            break;
        }
    }
    
    
    /**
     * 由已经建立的socket 进行连接反向连
     * @throws Exception 
     * @throws UnknownHostException 
     */
    public void startClient() throws Exception{
        
        while(true){
            try {
                if(RunServer.socket!=null){
                    break;
                }
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        
        // 与服务器建立连接
        Socket socket=new Socket(RunServer.socket.getInetAddress().getHostAddress(), 8888);
        System.out.println("连接建立成功...");
        
        //向服务器写入流
        OutputStream os=socket.getOutputStream();
        BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os));
        Scanner input=new Scanner(System.in);
        
        while(true){
            System.out.println("输入信息：");
            bw.write(input.next());
            bw.newLine();
            bw.flush();
        }
    }
    
    /**
     * 通过IP与服务器建立连接
     * @throws Exception 
     * @throws UnknownHostException 
     */
    public void startClient(String ip) throws Exception{
        // 与服务器建立连接
        Socket socket=new Socket(ip, 8888);
        System.out.println("连接建立成功...");
        
        //向服务器写入流
        OutputStream os=socket.getOutputStream();
        BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os));
        Scanner input=new Scanner(System.in);
        
        while(true){
            bw.write(input.next());
            bw.newLine();
            bw.flush();
        }
    }
}

main :

package com.start;
 
import com.server.RunServer;
 
public class Go {
 
    public static void main(String[] args) throws Exception {
        // TODO Auto-generated method stub
        RunServer rs=new RunServer();
        rs.startServer();
    }
 
}

Effet : J'utilise une machine virtuelle plus une machine locale

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!