TCP协议实现一对一聊天与UDP协议实现群聊

tcp一对一聊天：

服务端代码

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;}@Overridepublic 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;}@Overridepublic 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("A说："+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();}}}}
}

2，客户端代码

运行服务端代码后，再运行客户端代码，即可实现一对一聊天。

import 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{@Overridepublic 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;}@Overridepublic 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("B说："+mr);}}catch (Exception e){e.printStackTrace();}finally {if (br!=null){try {br.close();} catch (IOException e) {e.printStackTrace();}}}}
}

udp 群聊：

代码：

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.net.*;
import java.io.IOException;
import java.lang.String;public class liaotian extends JFrame{private static final int DEFAULT_PORT=8899;private JLabel stateLB;private JTextArea centerTextArea;private JPanel southPanel;private JTextArea inputTextArea;private JPanel bottomPanel;private JTextField ipTextField;private JTextField remotePortTF;private JButton sendBT;private JButton clearBT;private DatagramSocket datagramSoket;private void setUpUI(){setTitle("聊天");setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setSize(400,400);setResizable(false);//窗口大小不可改变setLocationRelativeTo(null);//设置窗口相对于指定组件的位置stateLB=new JLabel("weijianting");stateLB.setHorizontalAlignment(JLabel.RIGHT);centerTextArea=new JTextArea();centerTextArea.setEditable(false);centerTextArea.setBackground(new Color(211,211,211));southPanel=new JPanel(new BorderLayout());inputTextArea=new JTextArea(5,20);bottomPanel=new JPanel(new FlowLayout(FlowLayout.CENTER,5,5));ipTextField=new JTextField("127.0.0.1",8);remotePortTF=new JTextField(String.valueOf(DEFAULT_PORT),3);sendBT=new JButton("发送");clearBT=new JButton("清屏");bottomPanel.add(ipTextField);bottomPanel.add(remotePortTF);bottomPanel.add(sendBT);bottomPanel.add(clearBT);southPanel.add(new JScrollPane(inputTextArea),BorderLayout.CENTER);southPanel.add(bottomPanel,BorderLayout.SOUTH);add(stateLB,BorderLayout.NORTH);add(new JScrollPane(centerTextArea),BorderLayout.CENTER);add(southPanel,BorderLayout.SOUTH);setVisible(true);}
private void setListener(){sendBT.addActionListener(new ActionListener(){public void actionPerformed(ActionEvent e){final String ipAddress=ipTextField.getText();final String remotePort=remotePortTF.getText();if(ipAddress==null||ipAddress.trim().equals("")||remotePort==null||remotePort.trim().equals("")){JOptionPane.showMessageDialog(liaotian.this,"请输入IP地址和端口号");return;}if(datagramSoket==null||datagramSoket.isClosed()){JOptionPane.showMessageDialog(liaotian.this,"监听未成功");return;}String sendContent=inputTextArea.getText();byte[] buf=sendContent.getBytes();try{centerTextArea.append("我对"+ipAddress+":"+remotePort+"说:\n"+inputTextArea.getText()+"\n\n");centerTextArea.setCaretPosition(centerTextArea.getText().length());datagramSoket.send(new DatagramPacket(buf,buf.length,InetAddress.getByName(ipAddress),Integer.parseInt(remotePort)));inputTextArea.setText("");}catch(IOException e1){JOptionPane.showMessageDialog(liaotian.this, "出错了，发送不成功");e1.printStackTrace();}};});clearBT.addActionListener(new ActionListener(){public void actionPerformed(ActionEvent e){centerTextArea.setText("");}});
}
private void initSocket(){int port=DEFAULT_PORT;while(true){try{if(datagramSoket!=null&&!datagramSoket.isConnected()){datagramSoket.close();}try{port=Integer.parseInt(JOptionPane.showInputDialog(this,"请输入端口号","端口号",JOptionPane.QUESTION_MESSAGE));if(port<1||port>65535){throw new RuntimeException("端口号超出范围");}}catch(Exception e){JOptionPane.showMessageDialog(null,"你输入的端口不正确，请输入1~65535之间的数");continue;}datagramSoket=new DatagramSocket(port);startListen();stateLB.setText("已在"+port+"端口监听");break;}catch(SocketException e){JOptionPane.showMessageDialog(this, "端口号被占用，请重新设置端口");stateLB.setText("当前未启动监听");}}
}
private void startListen(){new Thread(){private DatagramPacket p;public void run(){byte[] buf=new byte[1024];p=new DatagramPacket(buf,buf.length);while(!datagramSoket.isConnected()){try{datagramSoket.receive(p);centerTextArea.append(p.getAddress().getHostAddress()+":"+((InetSocketAddress)p.getSocketAddress()).getPort()+"对我说：\n"+new String(p.getData(),0,p.getLength())+"\n\n");centerTextArea.setCaretPosition(centerTextArea.getText().length());}catch(IOException e){e.printStackTrace();}}}}.start();
}public static void main(String[] args) {liaotian a=new liaotian();a.setUpUI();a.initSocket();a.setListener();}}

 

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

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

相关文章

银河麒麟v10系统SSH远程管理及切换root用户的操作方法

银河麒麟v10系统SSH远程管理及切换root用户的操作方法

&#x1f4da;&#x1f4da; &#x1f3c5;我是默&#xff0c;一个在CSDN分享笔记的博主。&#x1f4da;&#x1f4da; ​​ &#x1f31f;在这里&#xff0c;我要推荐给大家我的专栏《Linux》。&#x1f3af;&#x1f3af; &#x1f680;无论你是编程小白&#xff0c;还是有一…
阅读更多...
word一键接受所有修订并保留修订痕迹

word一键接受所有修订并保留修订痕迹

目的&#xff1a;让word修订插入的内容在接受修订后保留痕迹。 文章目录 目的&#xff1a;让word修订插入的内容在接受修订后保留痕迹。1. 打开批注的word文件2. 同时按住&#xff1a;*AltF11*&#xff0c;然后右键&#xff1a;Normal -->插入--> 模块3. 在出现的代码框中…
阅读更多...
Go json 差异比较 json-diff(RFC6902)

Go json 差异比较 json-diff(RFC6902)

Go json 差异比较 json-diff(RFC 6902) 毕业设计中过程中为了比较矢量图的差异而依据 RFC 6902 编写的一个包&#xff0c;现已开源&#xff1a; Json-diff 使用 go get -u github.com/520MianXiangDuiXiang520/json-diff序列化与反序列化 与官方 json 包的序列化和反序列化不…
阅读更多...
手把手教你玩转ESP8266（原理+驱动）

手把手教你玩转ESP8266（原理+驱动）

在嵌入式开发中&#xff0c;无线通信的方式有很多&#xff0c;其中 WIFI 是绕不开的话题。说到 WIFI 通信&#xff0c;就不得不提 ESP8266了。 ESP8266 是一款高性能的 WIFI 串口模块&#xff0c;实现透明传输。只要有一定的串口知识&#xff0c;不需要知道 WIFI 原理就可以上…
阅读更多...
C语言中的一维数组与二维数组

C语言中的一维数组与二维数组

目录 一维数组数组的创建初始化使用在内存中的存储 二维数组创建初始化使用在内存中的存储 数组越界 一维数组 数组的创建 数组是一组相同类型元素的集合。 int arr1[10]; char arr3[10]; float arr4[10]; double arr5[10];下面这个数组能否成功创建&#xff1f; int count…
阅读更多...
建筑可视化数据大屏汇总，UI源文件（PC端大屏设计）

建筑可视化数据大屏汇总，UI源文件（PC端大屏设计）

酷炫的大屏设计让数据更好的展现&#xff0c;方便业务人员分析数据&#xff0c;辅助领导决策。现在分享大屏Photoshop源文件&#xff0c;以下为部分截图示意。 划重点&#xff1a;文末可获得完整素材包~ 01 科技建筑平台数据可视化 02 建筑公司可视化数据汇总平台 03 深蓝…
阅读更多...
字符统计[c]

字符统计[c]

#include<stdio.h> #include<string.h> int main() {int a,b,c;abc0;char s[100];int i0;while(1){i;scanf("%c",&s[i]);if(s[i]?)break;}for(int k1;k<i;k){if(s[k]>48&&s[k]<57){a;//数字}else if((s[k]>65&&s[k]<…
阅读更多...
透析跳跃游戏

透析跳跃游戏

关卡名 理解与贪心有关的高频问题 我会了✔️ 内容 1.理解跳跃游戏问题如何判断是否能到达终点 ✔️ 2.如果能到终点&#xff0c;如何确定最少跳跃次数 ✔️ 1. 跳跃游戏 leetCode 55 给定一个非负整数数组&#xff0c;你最初位于数组的第一个位置。数组中的每个元素代表…
阅读更多...
QT使用SQLite 超详细（增删改查、包括对大量数据快速存储和更新）

QT使用SQLite 超详细（增删改查、包括对大量数据快速存储和更新）

QTSQLite 在QT中使用sqlite数据库&#xff0c;有多种使用方法&#xff0c;在这里我只提供几种简单&#xff0c;代码简短的方法&#xff0c;包括一些特殊字符处理。在这里也给大家说明一下&#xff0c;如果你每次要存储的数据量很大&#xff0c;建议使用事务&#xff08;代码中…
阅读更多...
孩子还是有一颗网安梦——Bandit通关教程：Level 1 → Level 2

孩子还是有一颗网安梦——Bandit通关教程：Level 1 → Level 2

&#x1f575;️‍♂️ 专栏《解密游戏-Bandit》 &#x1f310; 游戏官网&#xff1a; Bandit游戏 &#x1f3ae; 游戏简介&#xff1a; Bandit游戏专为网络安全初学者设计&#xff0c;通过一系列级别挑战玩家&#xff0c;从Level0开始&#xff0c;逐步学习基础命令行和安全概念…
阅读更多...
Anaconda安装

Anaconda安装

1.Anaconda下载路径 官网最新版本&#xff1a;https://www.anaconda.com/products/distribution/ 官网历史版本&#xff1a;https://repo.anaconda.com/archive/ 清华大学开源软件镜像站&#xff1a;https://mirrors.tuna.tsinghua.edu.cn/anaconda/archive/ 2.和python版本关系…
阅读更多...
Caching the Application Engine Server 缓存应用程序引擎服务器

Caching the Application Engine Server 缓存应用程序引擎服务器

Caching the Application Engine Server 缓存应用程序引擎服务器 Application Engine caches metadata just like the application server. This caching enhances performance because a program can refer to the local cache for any objects that it uses. 应用程序引擎…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023