import lombok.NoArgsConstructor;
//网络传输请求 重点是要实现序列化 否则不能进行io传输
@Data
@AllArgsConstructor
@NoArgsConstructor
public class RpcRequest implements Serializable{
//方法编号
int methodNum;
//消息体
String message;
}
//消费者端
package consumer.nio;
import entity.RpcRequest;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetSocketAddress;
import java.nio.channels.SocketChannel;
import java.util.Scanner;
//阻塞NIO消费端 解决沾包问题
public class NIOBlockingClient {
public static void start(String HostName, int PORT) throws IOException {
start0(HostName,PORT);
}
//真正启动在这
private static void start0(String hostName, int port) throws IOException {
//得到一个网络通道
SocketChannel socketChannel = SocketChannel.open();
System.out.println("-----------服务消费方启动-------------");
//设置阻塞
socketChannel.configureBlocking(true);
//建立链接 阻塞连接 但我们是要等他连接上
socketChannel.connect(new InetSocketAddress(hostName,port));
//真正的业务逻辑 等待键盘上的输入 进行发送信息
Scanner scanner = new Scanner(System.in);
//输入输出通道都放在外面
ObjectOutputStream outputStream = new
ObjectOutputStream(socketChannel.socket().getOutputStream());
ObjectInputStream objectInputStream = new
ObjectInputStream(socketChannel.socket().getInputStream());
//都是阻塞等待 发完了 接收完了 才能进行下一步 不然会报异常
while (true)
剩余127页未读，继续阅读
