Java 实现TCP一对一聊天，UDP协议实现群聊

用TCP编程实现一对一式聊天，并用多线程解决了处于同一线程中的问题。
客户端代码：mport java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
 
public class ChatSocketClient {
    public static void main(String[] args) {
 
        try {
            Socket socket =new Socket("127.0.0.1",8888);
            System.out.println("连接成功！");
            new ClientSend(socket).start();
            new Clientreive(socket).start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
/**
 * 用于发送消息线程类
 */
class ClientSend extends Thread{
    @Override
    public void run() {
        this.sendMsy();
    }
    private Socket socket;
    public ClientSend(Socket socket){
        this.socket  =socket;
    }
    /**
     * 发送消息
     */
    private void sendMsy(){
        Scanner scanner =null;
        PrintWriter pw =null;
        try{
            scanner =new Scanner(System.in);
            pw =new PrintWriter(this.socket.getOutputStream());
            while(true){
                String str =scanner.nextLine();
                pw.println(str);
                pw.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (scanner!=null){
                scanner.close();
            }
            if (pw!=null){
                pw.close();
            }
            if (socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
 
/**
 *用于接收消息线程类
 */
class Clientreive extends Thread{
    private Socket socket=null;
    public Clientreive(Socket socket){
        this.socket =socket;
    }
 
    @Override
    public void run() {
        this.receiveMsg();
    }
    /**
     * 用于接收对方消息
     */
    private void receiveMsg(){
        BufferedReader br =null;
        try{
            br =new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            while(true){
                String mr = br.readLine();
                System.out.println("他说"+mr);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (br!=null){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
 
        }
    }
}服务端代码： import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
 
/**
 * 发送消息线程
 */
class Send extends Thread{
    private Socket socket;
    public Send(Socket socket){
        this.socket  =socket;
    }
    @Override
    public void run() {
        this.sendMsy();
    }
    /**
     * 发送消息
     */
    private void sendMsy(){
        Scanner scanner =null;
        PrintWriter pw =null;
        try{
            scanner =new Scanner(System.in);
            pw =new PrintWriter(this.socket.getOutputStream());
            while(true){
                String str =scanner.nextLine();
                pw.println(str);
                pw.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (scanner!=null){
                scanner.close();
            }
            if (pw!=null){
                pw.close();
            }
            if (socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}
 
/**
 * 接收消息的线程
 */
class receive extends Thread{
    private Socket socket=null;
    public receive(Socket socket){
        this.socket =socket;
    }
 
    @Override
    public void run() {
        this.receiveMsg();
    }
    /**
     * 用于接收对方消息
     */
    private void receiveMsg(){
        BufferedReader br =null;
        try{
            br =new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
            while(true){
                String mr = br.readLine();
                System.out.println("他说"+mr);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (br!=null){
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
 
        }
    }
}
 
public class ChatSocketServer {
    public static void main(String[] args) {
        ServerSocket serverSocket =null;
        try{
            serverSocket =new ServerSocket(8888);
            System.out.println("服务端已启动等待连接");
            Socket socket = serverSocket.accept();
            System.out.println("连接成功！");
            new Send(socket).start();
            new receive(socket).start();
        }catch(Exception e){
            e.printStackTrace();
        }finally {
            if (serverSocket!=null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

实现服务端对话框：
其中可自行更改对话框大小样式等配置。

 

  1. package com.ex.controller;
      
     import javax.servlet.http.HttpServletRequest;
     import javax.swing.*;
     import java.awt.*;
     import java.awt.event.*;
     import java.io.*;
     import java.net.*;
     public class QqMain extends JFrame implements ActionListener{
         public static void main(String[] args){
      
             InetAddress ia = null;
             try {
                 ia = ia.getLocalHost();
                 String localip = ia.getHostAddress();
                 System.out.println("本机的ip是 ：" + localip);
             } catch (Exception e) {
                 // TODO Auto-generated catch block
                 e.printStackTrace();
             }
             new QqMain();
         }
      
      
         // 说明：一个类需要页面的显示，则那个类要继承JFrame。
         // 属性
         // 文本域
         private JTextArea jta;
         // 滚动条
         private JScrollPane jsp;
         // 面板里面是文本框和按钮
         private JPanel jp;
         private JTextField jtf;
         private JButton jb ;
      
         BufferedWriter bw  = null;
      
         // 构造器
         public QqMain(){
      
             // 初始化上面的属性
             jta = new JTextArea();
      
             // 将文本域添加到滚动条中
             jsp = new JScrollPane(jta);
             jp = new JPanel();
             jtf =new JTextField(15);
             jb = new JButton("发送");
      
             // 把按钮和文本框添加到面板中
             jp.add(jtf);
             jp.add(jb);
      
             // 把滚动条和面板添加到JFrame中去
             this.add(jsp,BorderLayout.CENTER); //这个设置在中间
             this.add(jp,BorderLayout.SOUTH); //南
      
             this.setTitle("qq聊天");
             this.setSize(500,500);
             this.setLocation(200, 200);
             this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
             this.setVisible(true);
      
             /***********TCP协议*************/
             jb.addActionListener(this);  // 这是按钮点击使用
             // 回车键的监听事件 在接口KeyListener中
             //jtf.addKeyListener(this);
      
      
             jtf.addKeyListener(new KeyAdapter() {
                 public void keyTyped(KeyEvent e) {
                     if((char)e.getKeyChar()==KeyEvent.VK_ENTER) {
                         useVoid();
                     }
                 }
             });
      
             try{
                 // 1.创建一个服务端的套接字
                 ServerSocket serverSocket = new ServerSocket(8888);
      
                 //2.等待客户端的连接
                 Socket socket = serverSocket.accept();
      
                 // 3.获取socket通道的输入流(输入流的读取方式为一行一行的读取方式 ----> readLine())
                 BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
      
                 // 4.获取通道的输入流(也是一行一行的写出  BufferedWriter ->newLine())
                 // 当用户点击“发送”按钮的时候才会，写出数据
                 bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
                 String line = null;
                 while((line = br.readLine()) !=null){
                     // 将读取的数据拼接到文本域中显示
                     jta.append(line + "\n");
                 }
      
      
                 // 5.关闭socket通道
                 serverSocket.close();
      
             }catch(IOException e){
                 e.printStackTrace();
             }
      
             /************************/
      
      
         }
         // 点击按钮所实现的方法
         public void actionPerformed(ActionEvent e){
             useVoid();
         }
      
         public void useVoid(){
             // 1.获取文本框中的内容
             String text = jtf.getText();
             text = "服务端对客户端说：" + text;
             // 自己显示
             jta.append(text + "\n");
             // 2.发送
             try{
                 // 4.发送
                 bw.write(text);
                 bw.newLine(); // 换行
                 bw.flush();  // 刷新
                 // 5.清空文本框
                 jtf.setText("");
             }catch (IOException e1){
                 e1.printStackTrace();
             }
         }
      
      
         /*public void KeyPressed(KeyEvent e){
             //回车键
             System.out.println("按钮数字");
         }
         public void KeyTyped(KeyEvent e){
         }
         public void KeyReleased(KeyEvent e){
         }*/
         //行为
     }必须先启动服务端再启动客户端才可，如果是两台电脑的情况下，只需要获得其中一个电脑的ip进行服务器启动，另一个进行链接即可。就可实现实时对话
     效果展示：服务器端：
     1.1 服务器端继承JFrame框架，添加组件。
     1.2 创建服务器端socket。建立一个哈希表，用于存储客户端的昵称以及服务器端对于每个连接的客户端建立的输出流。
     1.3建立一个线程池，为每个连接的客户端分配一个执行线程。
     1.3调用服务器端Socket的accept（）函数，等待客户端的连接，每连接到一个客户端，线程池给相应的客户端分配一个线程。\n1.4每个线程内，调用服务器端Socket，封装getOutputStream（），获得服务器端Socket相对应于连接的客户端的输出流和输入流。输入流首先读取到客户端发送来的昵称。将客户端的昵称和服务器端的输出流存储在哈希表中，并遍历整个哈希表，将某人上线的通知发送给所有的在线客户端。
     1.5客户端将信息发送给服务器端，当服务器端传来的信息符合“@私聊对象：私聊信息”的格式时，服务器端认为这是私聊信息。服务器端将把私聊对象的昵称从信息中提取出来，通过哈希表找到与昵称对应的输出流。将私聊信息通过输出流发送给私聊对象。
     当不是私聊信息时，服务器遍历整个哈希表，通过每个客户端对应的输出流发送给每个客户端。
     1.6当客户端下线时，服务器端将移除哈希表中对应存储的客户端昵称以及输出流。并通知在线的每个客户端，某人已下线。
     （二） 客户端：
     2.1 客户端继承框架JFrame，添加各种组件。
     2.2 创建客户端Socket，设置请求连接服务器端IP，以及使用的端口号。
     2.3 封装客户端Socket的getInputStream()函数，获得客户端Socket的输入流接受服务器端发来的信息，封装Socket的getOutputStream()函数，获得Socket的输出流向服务器端发送信息。
     2.4 通过向文本框添加动作事件监听器，监听文本框的输入。
     2.5 当与服务器端连接成功时，系统提醒输入昵称。系统将对输入的昵称进行检索。判断是否有重复的昵称。如有重复则创建不成功，继续输入。
     2.6 向服务器端发送信息时，如想对某人发送私聊信息，则需输入符合“@私聊对象的呢称：私聊信息”的格式，此时只有私聊对象和本人可以接收到。否则，发送的信息为公聊信息，所有的客户端都能够收到。
     2.7 客户端不断接受服务器端的信息显示在文本域。











本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/255439.html


如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！












相关文章










python深浅拷贝








python深浅拷贝




【 一 】Python 深拷贝和浅拷贝概念理解 个人见解：       浅拷贝，指的是重新分配一块内存，创建一个新的对象，但里面的元素是原对象中各个子对象的引用。 深拷贝，是指重新分配一块内存，创建一个新的对象&…




阅读更多...

















Axure动态面板控制








Axure动态面板控制




首先创建一个项目，拖拽几个矩形喝一个动态面板 然后双击动态面板添加状态state1,state2,state3 然后分别在state1,state2,state3编辑导航对应的内容。 
接下来就是添加交互事件，将不同导航对应不同的state. 
点击“交互”->鼠标点击->进入交互编辑…




阅读更多...

















数组常用方法








数组常用方法




1、filter 筛选 
筛选数组中带有某个id的对象 
let list[{id:1,name:111},{id:2,name:222},{id:3,name:333},];
let alist.filter((item)>{return item.id1 });
console.log(a)2、findIndex var idx  list.findIndex((item) > {return item  2;});返回的idx是该元素在数组…




阅读更多...

















Vellum —— Vellum Solver








Vellum —— Vellum Solver




目录 
Solver 
Collision 
Forces 
Advanced 
Secondary Constraint Pass 
Multi-Pass Solve 
Motion 
Sleeping 
Grain Collisions  
Fluids 
Minimal Solver Vellum Solver SOP是DOP的封装，以简化vellum的解算；第一个端口是geometry，第二个…




阅读更多...

















软件系统应用开发安全指南








软件系统应用开发安全指南




2.1.应用系统架构安全设计要求 2.2.应用系统软件功能安全设计要求 2.3.应用系统存储安全设计要求 2.4.应用系统通讯安全设计要求 2.5.应用系统数据库安全设计要求 2.6.应用系统数据安全设计要求 全资料获取进主页。




阅读更多...

















Java多线程：代码不只是在‘Hello World‘








Java多线程：代码不只是在‘Hello World‘




Java线程好书推荐 概述01 多线程对于Java的意义02 为什么Java工程师必须掌握多线程03 Java多线程使用方式04 如何学好Java多线程写在末尾： 主页传送门：📀 传送  概述 摘要：互联网的每一个角落，无论是大型电商平台的秒杀…




阅读更多...

















汽车电子 -- CAN文件格式ASC








汽车电子 -- CAN文件格式ASC




Vector提供了两种记录数据格式的格式规范：BLF和ASC。 先讲讲ASC。 参看：图文详解CAN Log文件 - ASC文件格式  
一、ASC文件格式 
在Vector提供的 CAN_LOG_TRIGGER_ASC_Format.pdf 提取码：ltjv 文件中，规定了CANoe/CANalyzer ASC记…




阅读更多...

















亚马逊，速卖通，沃尔玛构建稳定高成功率的测评补单环境系统：关键步骤解析








亚马逊，速卖通，沃尔玛构建稳定高成功率的测评补单环境系统：关键步骤解析




亚马逊对于跨境电商行业来说并不陌生，现在越来越多的人想进入亚马逊这个跨境电商平 台。因此随着越来越多的商家进入这个市场，亚马逊的竞争力也在不断上升。在亚马逊的平台，Review 直接影响着亚马逊对卖家账号进行评定的各项因素，…




阅读更多...

















低代码正在改变软件开发方式








低代码正在改变软件开发方式




无论你是一个初级的开发者还是一位经验丰富的专家，低代码都将为你提供了一个突破研发限制的机会。这种开发方式让我们能够在短时间内构建高质量的应用程序。接下来，我将详细展开低代码的概念，解决问题的能力，适用于哪些业务场景。…




阅读更多...

















阿里云效部署前后端








阿里云效部署前后端




静态站点到OSS 
阿里云-云效，阿里云企业级一站式 DevOps，可以免费使用（会限制人数、流水线数量等，个人项目够用了）。相关文章 CI 持续集成 - 阿里云云效 
OSS 是对象存储的意思，一般一个项目对应一个 Bucke…




阅读更多...

















数字营销影响消费者行为的 6 种方式








数字营销影响消费者行为的 6 种方式




如果您正在考虑转向在线市场，那么这个决定就好了！没有什么比数字营销更强大的了。但是，在开始之前，请了解数字营销如何影响消费者行为。由于客户是任何企业的基石，因此跟踪消费者行为至关重要。  数据分析在识别潜在客…




阅读更多...

















INA219电流感应芯片_程序代码








INA219电流感应芯片_程序代码




详细跳转借鉴链接INA219例程此处进行总结 
简单介绍一下 INA219： 
1、 输入脚电压可以从 0V~26V,INA219 采用 3.3V/5V 供电. 2、 能够检测电流，电压和功率，INA219 内置基准器和乘法器使之能够直接以 A 为单位 读出电流值。 3、 16 位可编程地…




阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023