java 中提供了多样化的通信框架，包括：rmi：用于在 jvm 间进行远程方法调用。socket：低级通信框架，允许直接与其他主机通信。jms：标准化的消息传递框架，支持可靠和可扩展的消息传递。netty：高性能异步事件驱动网络框架，支持多种协议。
Java 中用于通信的常用框架
在 Java 应用开发中，经常需要进行各种通信操作，例如与远程服务器通信、与客户端通信、消息传递等。为了简化和标准化这些操作，Java 中提供了多种通信框架。
1. RMI（远程方法调用）
立即学习“Java免费学习笔记（深入）”；
RMI 允许在 Java 虚拟机（JVM）之间进行远程方法调用。它提供了一个透明的 API，使远程方法的调用方式与本地方法调用几乎相同。
示例：
// 服务端接口
public interface RemoteService {
String getMessage();
}
// 服务端实现
public class RemoteServiceImpl implements RemoteService {
@Override
public String getMessage() {
return "Hello, world!";
}
}
// 客户端
public class RemoteClient {
public static void main(String[] args) {
try {
// 获取远程服务引用
RemoteService service = (RemoteService) Naming.lookup("rmi://localhost:1099/RemoteService");
// 调用远程方法
String message = service.getMessage();
System.out.println("Received message: " + message);
} catch (Exception e) {
e.printStackTrace();
}
}
}2. Socket
Socket 是一个低级通信框架，提供对底层网络协议的访问。它允许应用程序直接与网络上的其他主机通信。
weiit-saas开源电商SaaS系统
下载
weiit-saas是一款Java开源项目，由weiit团队自研，意在通过技术封装，帮助企业一键生成小程序、公众号，让企业拥有独立品牌的自营商城。weiit-saas是完全开源电商SaaS系统，属于weiit开源的社区版，旧版已不在维护和更新，仅供学习和参考，新版saas从底层架构到前后端UI设计已经全面优化和升级。 主要特点1、项目采用Spring+SpringMVC+Mybatis主流开源框架
示例：
// 服务端
public class SocketServer {
public static void main(String[] args) {
try {
// 创建ServerSocket并监听端口
ServerSocket serverSocket = new ServerSocket(1234);
while (true) {
// 接受客户端连接
Socket clientSocket = serverSocket.accept();
// 处理客户端请求
Thread clientThread = new Thread(() -> {
try {
// 读取客户端消息
BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
String message = in.readLine();
// 回复客户端消息
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
out.write("Hello, client!" + "\n");
out.flush();
} catch (IOException e) {
e.printStackTrace();
} finally {
clientSocket.close();
}
});
clientThread.start();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
// 客户端
public class SocketClient {
public static void main(String[] args) {
try {
// 创建Socket并连接到服务端
Socket clientSocket = new Socket("localhost", 1234);
// 发送消息到服务端
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
out.write("Hello, server!" + "\n");
out.flush();
// 接收服务端消息
BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
String message = in.readLine();
System.out.println("Received message: " + message);
} catch (Exception e) {
e.printStackTrace();
}
}
}3. JMS（Java 消息服务）
JMS 是一个标准化的消息传递框架，允许应用程序发送和接收异步消息。它提供了可靠和可扩展的消息传递功能。
示例：
import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;
// 消息发送者
public class MessageProducer {
public static void main(String[] args) {
try {
// 创建ActiveMQ连接和会话
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建主题和消息生产者
Destination destination = session.createTopic("myTopic");
MessageProducer producer = session.createProducer(destination);
// 发送消息
TextMessage message = session.createTextMessage("Hello, world!");
producer.send(message);
// 关闭资源
producer.close();
session.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
// 消息消费者
public class MessageConsumer {
public static void main(String[] args) {
try {
// 创建ActiveMQ连接和会话
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 创建主题和消息消费者
Destination destination = session.createTopic("myTopic");
MessageConsumer consumer = session.createConsumer(destination);
// 监听消息
connection.start();
while (true) {
Message message = consumer.receive();
if (message != null) {
System.out.println("Received message: " + ((TextMessage) message).getText());
}
}
// 关闭资源
consumer.close();
session.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}4. Netty
Netty 是一个高性能的异步事件驱动网络应用框架，支持多种协议，例如 TCP、UDP、HTTP 等。
示例：
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
// 服务端
public class NettyServer {
public static void main(String[] args) {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class) 
