Java聊天程序

软件发布|下载排行|最新软件

当前位置:首页IT学院IT技术

Java聊天程序

GYN1996   2022-09-29 我要评论

利用Java编写聊天程序,供大家参考,具体内容如下

首先计算机网络有两种传输层协议:TCP(面向连接),UDP(面向无连接)。今天就介绍基于这两种协议的聊天程序。

先查明自己电脑的主机名

右键我的电脑-->属性

一、基于UDP的聊天程序

1.基于UDP的发送端

package cn.com;

/**
 * 基于UDP
 * 聊天发送端
 */
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class Send {

    public static void main(String[] args) throws IOException {
        @SuppressWarnings("resource")
        DatagramSocket ds = new DatagramSocket();
        Scanner sc = new Scanner(System.in);
        String line = null;
        while ((line = sc.nextLine()) != null) {
            byte[] buf = line.getBytes();
            int length = buf.length;
            InetAddress address = InetAddress.getByName("1-PC21");//主机名
            DatagramPacket dp = new DatagramPacket(buf, length, address, 10086);   //10086为自己设置的端口号
            ds.send(dp);
        }
        sc.close();
    }

}

2.基于UDP的接收端

package cn.com;

/**
 * 基于UDP
 * 聊天接收端
 */
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class Receive {

    public static void main(String[] args) throws IOException {
        @SuppressWarnings("resource")
        DatagramSocket ds = new DatagramSocket(10086);//端口号需一致

        while (true) {
            byte[] b = new byte[1024 * 1];
            int length = b.length;
            DatagramPacket dp = new DatagramPacket(b, length);
            ds.receive(dp);

            byte[] data = dp.getData();
            int length2 = dp.getLength();
            String hostAddress = dp.getAddress().getHostAddress();
            String s = new String(data, 0, length2);
            System.out.println(s + "来自" + hostAddress);
        }

    }

}

3.先运行接收端,在运行发送端

发送端发送“Hello World”,“My name is Tom”。

接收端收到信息

二、基于TCP的聊天程序

1.客户端

package cn.com;
/**
 * 基于TCP
 * 聊天系统客户端
 */
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class Client {

    public static void main(String[] args) throws IOException {
        InetAddress address = InetAddress.getByName("1-PC21");//主机名
        int port = 10089;

        Scanner sc = new Scanner(System.in);
        String line = null;
        while ((line = sc.nextLine()) != null) {
            @SuppressWarnings("resource")
            Socket socket = new Socket(address, port);   //socket要在循环体中定义
            OutputStream os = socket.getOutputStream();
            os.write(line.getBytes());

            // 客户端接收服务端返回的消息(输入流)
            InputStream is = socket.getInputStream();
            byte[] b = new byte[1024 * 1];
            int len = is.read(b);
            String s = new String(b, 0, len);
            System.out.println(s);
        }
        sc.close();

    }

}

2.服务端

package cn.com;

/**
 * 基于TCP
 * 聊天系统服务端
 */
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

    public static void main(String[] args) throws IOException {
        @SuppressWarnings("resource")
        ServerSocket ss = new ServerSocket(10089);

        while (true) {
            Socket accept = ss.accept();    //循环中用到accept,所以要在循环中新建定义
            InputStream is = accept.getInputStream();
            byte[] b = new byte[1024 * 1];
            int len = is.read(b);
            String s = new String(b, 0, len);
            System.out.println("已接收客户端内容-->" + s);

            // 给客户端返回数据
            OutputStream os = accept.getOutputStream();
            String content = "客户端接收成功";
            os.write(content.getBytes());

            os.close();
            is.close();
            accept.close();
        }

    }

}

3.还是先打开服务端,再打开客户端,发送信息

客户端发送:“今天星期四”,“天气很好” 两条信息。

服务端收到信息:

Copyright 2022 版权所有 软件发布 访问手机版

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 联系我们