欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Socket即时通信(一)

程序员文章站 2022-06-05 22:05:03
...

   一、 需要一个服务端+一个客户端。

首先启动服务端

(1)服务端显示:这里是服务器,客户端说:***服务器即将启动,等待客户端连接***
启动客户端,直接发送信息给对应端口的服务端
(2)客户端发送:账号:administrative,密码:123
(3)服务端显示:这里是服务端,客户端说:账号:administrative,密码:123
(4)服务端发送:欢迎您!
(5)客户端显示:这里是客户端,服务器说:欢迎您!
1.服务端代码:
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args){
        try {
            //1.创建一个服务器端socket,ServerSocket,指定绑定的端口,并监听此端口
            ServerSocket serverSocket = new ServerSocket(8888);
            System.out.println("***服务器即将启动,等待客户端连接***");
            //2.调用accept()方法开始监听,等待客户端的连接
            Socket socket = serverSocket.accept();
            //3.获取输入流,取得客户端提交的消息
            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String info = null;
            while ((info = br.readLine()) != null){
                System.out.println("这里是服务器,客户端说:" + info);
            }
            socket.shutdownInput();

            //4.获取输出流,响应客户端的请求
            OutputStream os = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(os);
            pw.write("欢迎您!");
            pw.flush();

            //5.关闭资源
            pw.close();
            os.close();
            br.close();
            isr.close();
            is.close();
            socket.close();
            serverSocket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
2.客户端代码
import java.io.*;
import java.net.Socket;

public class Client {

    public static void main(String[] args){
        try {
            //1.创建客户端socket实例,指定服务器地址和端口
            Socket socket = new Socket("localhost",8888);
            //2.获取输出流,向服务器发送信息
            OutputStream os = socket.getOutputStream();//字节输出流
            PrintWriter pw = new PrintWriter(os);//将输出流包装成打印流
            pw.write("账号:administrative,密码:123");
            pw.flush();//
            socket.shutdownOutput();//关闭输出流

            //3.获取输入流,接收服务器响应的消息
            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String info = null;
            while ((info = br.readLine()) != null){
                System.out.println("这里是客户端,服务器说:" + info);
            }

            //4.关闭资源
            br.close();
            isr.close();
            is.close();
            pw.close();
            os.close();
            socket.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

备注:本代码来自,慕课网视频讲解《Java Socket应用---通信是这样练成的》

只支持单次通信

相关标签: Socket 即时通信