Java使用MulticastSocket实现群聊应用程序
作者:allway2 发布时间:2021-09-23 12:12:29
本文实例为大家分享了Java使用MulticastSocket实现群聊应用程序的具体代码,供大家参考,具体内容如下
在这篇文章中,讨论了一个使用 MulticastSocket (Java Platform SE 7) 类的群聊应用程序。MulticastSocket 是一个 (UDP) DatagramSocket,具有加入 Internet 上其他多播主机“组”的附加功能。
import java.net.*;
import java.io.*;
import java.util.*;
public class GroupChat {
private static final String TERMINATE = "Exit";
static String name;
static volatile boolean finished = false;
public static void main(String[] args) {
if (args.length != 2)
System.out.println("Two arguments required: <multicast-host> <port-number>");
else {
try {
InetAddress group = InetAddress.getByName(args[0]);
int port = Integer.parseInt(args[1]);
Scanner sc = new Scanner(System.in);
System.out.print("Enter your name: ");
name = sc.nextLine();
MulticastSocket socket = new MulticastSocket(port);
// Since we are deploying
socket.setTimeToLive(0);
// this on localhost only (For a subnet set it as 1)
socket.joinGroup(group);
Thread t = new Thread(new ReadThread(socket, group, port));
// Spawn a thread for reading messages
t.start();
// sent to the current group
System.out.println("Start typing messages...\n");
while (true) {
String message;
message = sc.nextLine();
if (message.equalsIgnoreCase(GroupChat.TERMINATE)) {
finished = true;
socket.leaveGroup(group);
socket.close();
break;
}
message = name + ": " + message;
byte[] buffer = message.getBytes();
DatagramPacket datagram = new DatagramPacket(buffer, buffer.length, group, port);
socket.send(datagram);
}
} catch (SocketException se) {
System.out.println("Error creating socket");
se.printStackTrace();
} catch (IOException ie) {
System.out.println("Error reading/writing from/to socket");
ie.printStackTrace();
}
}
}
}
class ReadThread implements Runnable {
private MulticastSocket socket;
private InetAddress group;
private int port;
private static final int MAX_LEN = 1000;
ReadThread(MulticastSocket socket, InetAddress group, int port) {
this.socket = socket;
this.group = group;
this.port = port;
}
@Override
public void run() {
while (!GroupChat.finished) {
byte[] buffer = new byte[ReadThread.MAX_LEN];
DatagramPacket datagram = new DatagramPacket(buffer, buffer.length, group, port);
String message;
try {
socket.receive(datagram);
message = new String(buffer, 0, datagram.getLength(), "UTF-8");
if (!message.startsWith(GroupChat.name))
System.out.println(message);
} catch (IOException e) {
System.out.println("Socket closed!");
}
}
}
}
将文件另存为 GroupChat.java 并使用 javac 编译它,然后使用指定的两个命令行参数运行程序。多播主机由 D 类 IP 地址和标准 UDP 端口号指定。D 类 IP 地址的范围为 224.0.0.0 到 239.255.255.255(含)。地址 224.0.0.0 是保留地址,不应使用。
以下是上述程序的示例输出:
我们使用多播主机 IP 地址为 239.0.0.0,端口号为 1234(因为端口号 0 到 1023 被保留)。该组有 3 名成员:Ironman、CaptainAmerica 和 Groot。在发送消息之前首先启动所有三个终端,否则在启动终端之前发送的消息将丢失(因为没有合并缓冲区来存储消息。)我们在这个应用程序中需要两个线程。一个用于接受用户输入(使用 java.util.Scanner 类),另一个用于读取从其他客户端发送的消息。因此,我将执行读取工作的线程分离到 ReadThreadclass 中。要离开组,任何用户都可以键入退出以终止会话。
上述程序在单机上执行。套接字编程适用于分布式编程。相同的代码片段出现在安装了 Java 的不同机器上时可以满足该要求。这只是最基本的服务逻辑。如果前端开发出来,这个项目会更加吸引人。您可以使用 Java 的 AWT(抽象窗口工具包)或其高级对应物 Java Swing 来开发前端。由于这不是 Socket 编程的一部分,因此我将在不深入了解细节的情况下保持不变。
附加点:
您可以通过在通过网络发送消息之前执行加密来合并网络安全功能。
凯撒密码等原始技术或 RSA 等高级方法可用于执行加解密。您可以尝试使用 Java 的 RMI(远程方法调用)来执行相同的任务。
在这里,您可以最大限度地利用 Java 提供的抽象。但是,如果您的主要目标是效率,那么 Socket 编程是最佳选择。由于它不需要任何运行时支持,因此与 RMI 相比要快一些。
来源:https://blog.csdn.net/allway2/article/details/120155581
猜你喜欢
- 前言如今多线程编程已成为了现代软件开发中的重要部分,而并发编程中的线程同步问题更是一道难以逾越的坎。在Java语言中,synchronize
- 目录栈溢出(虚拟机栈和本地方法栈)产生原因解决思路堆溢出产生原因解决思路方法区和运行时常量池溢出产生原因解决思路本机直接内存溢出产生原因解决
- 一 应用规划: ※ 确定功能。 ※ 必须的界面及界面跳转的流程。
- spring-boot-starter-actuator提供服务健康检查和暴露内置的url接口。spring-cloud-starter-c
- static表示“全局”或者“静态”的意思,用来修饰成员变量和成员方法,也可以形成静态static代码块,但是Java语言中没有全局变量的概
- 1.对原生态jdbc程序中问题总结1.1 jdbc程序需求:使用jdbc查询mysql数据库中用户表的记录statement:向数据库中发送
- 最近学习了一下seata,由于nacos现在也挺火,于是学习了seata注册到nacos,然后集成springcloud1.nacos配置(
- 一个错误:多线程使用单一消费者下图显现了一种错误的使用KafkaConsumer的方法创建多个线程用来消费kafka数据多线程使用同一个Ka
- 一、前言一个完整的Java应用程序,当程序在运行时,即会调用该程序的一个入口函数来调用系统的相关功能,而这些功能都被封装在不同的class文
- Atomikos是一个为Java平台提供增值服务的并且开源类事务管理器,如果将事务统一注册到Atomikos中,则可以统一管理。常用于后台管
- 引言一个复杂的分布式系统,用户发起一个请求,这个请求可能调用几十到几百个服务,经过很多业务层,而每个业务又是多个机器集群,一个请求具体被随机
- 实例如下所示:package test;import java.util.ArrayList;import java.util.Collec
- 概述不知道大家在平时的开发过程中或者源码里是否留意过内部类,那有思考过为什么要有内部类,内部类都有哪几种形式,静态内部类和普通内部类有什么区
- 本文实例为大家分享了JDBC实现学生管理系统的具体代码,供大家参考,具体内容如下1、学生类package manage;import jav
- IDEA打成jar包并在windows后台运行一、IDEA打成jar包1、File=>Project Structure=>Pr
- 1 问题手写一个程序,完成List集合对象的逆序遍历2 方法创建List接口的多态对象向创建好list集合添加元素使用hasPrevious
- 什么是注解在早期的工作的时候 ,自定义注解写的比较多,可大多都只是因为 这样看起来 不会存在一堆代码耦合在一起的情况,所以使用了自定义注解,
- 1.配置代理系统管理---configure Global Security(全局安全设置)---Tcp port for inbound
- 定义Builder模式是一步步创建一个复杂对象的创建型模式,它允许用户在不知道内部构建细节的情况下,可以更精细的控制对象的构建过程。该模式是
- 如下所示://判断整数(int)private boolean isInteger(String str) {if (null == str