会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132808个问题
JAVA 全系列/第二阶段:JAVA 基础深化和提高/数据结构 1576楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 1579楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/智能电话本项目实战 1584楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/反射技术(旧) 1588楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/反射技术(旧) 1589楼

package H_Socket.C_Tcp;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 聊天室,一个客户端发送消息其他的客户端也可以接收到消息
 */
//创建一个消息接收线程
class ChatReceive extends Thread{
    BufferedReader bufferedReader;
    Socket socket;
    public ChatReceive(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            bufferedReader = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            while (true){
                synchronized ("a"){
                    //把从客户端接收到的信息给缓冲区
                    ChatServer.buf = bufferedReader.readLine();
                    //唤醒发送信息的线程对象
                    "a".notifyAll();
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (bufferedReader != null){
                    bufferedReader.close();
                }
                if (socket != null){
                    socket.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}
//创建一个消息发送线程
class ChatSend extends Thread{
    PrintWriter printWriter;
    Socket socket;
    public ChatSend(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            while (true){
                synchronized ("a"){
                    //让发送消息的线程处于等待状态
                    "a".wait();
                    //把接缓冲区的信息发送给其他的客户端
                    printWriter.println(ChatServer.buf);
                    printWriter.flush();
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (socket != null){
                    socket.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}
public class ChatServer {
    //定义公共区域
    public static String buf;
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        try {
            System.out.println("监听83端口");
            serverSocket = new ServerSocket(83);
            while(true){
                Socket socket = serverSocket.accept();
                System.out.println("连接到" + socket.getInetAddress());
                new ChatSend(socket).start();
                new ChatReceive(socket).start();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (serverSocket != null){
                    serverSocket.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}
package H_Socket.C_Tcp;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

/**
 * 在一个程序里既是客户端也可以是服务端,根据你输入的不同而不同
 */
//发送线程
class Send extends Thread{
    private Socket socket;
    private Scanner scanner;
    public Send(Socket socket){
        this.socket = socket;
    }
    PrintWriter printWriter = null;
    @Override
    public void run() {
        try {
            printWriter = new PrintWriter(this.socket.getOutputStream());
            scanner = new Scanner(System.in);
            while (true){
                String message = scanner.nextLine();
                printWriter.println(message);
                printWriter.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (scanner != null){
                    scanner.close();
                }
                if (printWriter != null){
                    printWriter.close();
                }
            }catch (Exception e){
                printWriter.println();
            }
        }
    }
}
//接收线程
class Receive extends Thread{
    private Socket socket;
    public Receive(Socket socket){
        this.socket = socket;
    }
    BufferedReader bufferedReader = null;
    @Override
    public void run() {
        try {
            bufferedReader = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            while (true){
               String string = bufferedReader.readLine();
               System.out.println("他说:" + string);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (bufferedReader != null){
                    bufferedReader.close();
                }
                if (socket != null){
                    socket.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}
public class GoodTcp {
    public static void main(String[] args) throws Exception {
        Socket socket = null;
        ServerSocket serverSocket = null;
        Scanner scanner = null;
        try {
            scanner = new Scanner(System.in);
            System.out.println("请输入:server,<port> 或者:<ip>,<port>");
            String s = scanner.nextLine();
            String[] arrays = s.split(",");
            if ("server".equals(arrays[0])){
                //启动服务端
                System.out.println("TCP服务端监听" + arrays[1] + "端口,等待连接");
                serverSocket = new ServerSocket(Integer.parseInt(arrays[1]));
                socket = serverSocket.accept();
                System.out.println("连接成功");
            }else {
                //启动客户端
                socket = new Socket(arrays[0],Integer.parseInt(arrays[1]));
                System.out.println("连接成功");
            }
            //启动发送线程
            new Send(socket).start();
            //启动接收线程
            new Receive(socket).start();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            try {
                if (serverSocket != null){
                    serverSocket.close();
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    }
}

显示连接成功,但是不能进行相互之间的通信

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 1590楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637