Spring Boot集成netty實現(xiàn)客戶端服務端交互示例詳解
更新時間：2018年12月27日 08:38:47 作者：琴_酒
這篇文章主要給大家介紹了關于Spring Boot集成netty實現(xiàn)客戶端服務端交互的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
前言
Netty 是一個高性能的 NIO 網(wǎng)絡框架，本文主要給大家介紹了關于SpringBoot集成netty實現(xiàn)客戶端服務端交互的相關內(nèi)容，下面來一起看看詳細的介紹吧
看了好幾天的netty實戰(zhàn),慢慢摸索,雖然還沒有摸著很多門道,但今天還是把之前想加入到項目里的
一些想法實現(xiàn)了,算是有點信心了吧(講真netty對初學者還真的不是很友好......)
首先,當然是在SpringBoot項目里添加netty的依賴了,注意不要用netty5的依賴,因為已經(jīng)廢棄了
<!--netty--> <dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.32.Final</version> </dependency>
將端口和IP寫入application.yml文件里,我這里是我云服務器的內(nèi)網(wǎng)IP,如果是本機測試,用127.0.0.1就ok
netty: port: 7000 url: 172.16.0.7
在這之后,開始寫netty的服務器,這里服務端的邏輯就是將客戶端發(fā)來的信息返回回去
因為采用依賴注入的方法實例化netty,所以加上@Component注釋
package com.safelocate.app.nettyServer;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Component;
import java.net.InetSocketAddress;
@Component
public class NettyServer {
//logger
private static final Logger logger = Logger.getLogger(NettyServer.class);
public void start(InetSocketAddress address){
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap = new ServerBootstrap()
.group(bossGroup,workerGroup)
.channel(NioServerSocketChannel.class)
.localAddress(address)
.childHandler(new ServerChannelInitializer())
.option(ChannelOption.SO_BACKLOG, 128)
.childOption(ChannelOption.SO_KEEPALIVE, true);
// 綁定端口，開始接收進來的連接
ChannelFuture future = bootstrap.bind(address).sync();
logger.info("Server start listen at " + address.getPort());
future.channel().closeFuture().sync();
} catch (Exception e) {
e.printStackTrace();
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}
當然,這里的ServerChannelInitializer是我自己定義的類,這個類是繼承ChannelInitializer<SocketChannel>的,里面設置出站和入站的編碼器和解碼器
package com.safelocate.app.nettyServer;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;
public class ServerChannelInitializer extends ChannelInitializer<SocketChannel> {
@Override
protected void initChannel(SocketChannel channel) throws Exception {
channel.pipeline().addLast("decoder",new StringDecoder(CharsetUtil.UTF_8));
channel.pipeline().addLast("encoder",new StringEncoder(CharsetUtil.UTF_8));
channel.pipeline().addLast(new ServerHandler());
}
}
最好注意被別decoder和encoder寫成了一樣的,不然會出問題(我之前就是不小心都寫成了StringDecoder...)
在這之后就是設置ServerHandler來處理一些簡單的邏輯了
package com.safelocate.app.nettyServer;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.channel.SimpleChannelInboundHandler;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
public class ServerHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelActive(ChannelHandlerContext ctx) {
System.out.println("channelActive----->");
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
System.out.println("server channelRead......");
System.out.println(ctx.channel().remoteAddress()+"----->Server :"+ msg.toString());
//將客戶端的信息直接返回寫入ctx
ctx.write("server say :"+msg);
//刷新緩存區(qū)
ctx.flush();
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
準備工作到這里,現(xiàn)在要做到就是去啟動這個程序
將AppApplication實現(xiàn)CommandLineRunner這個接口,這個接口可以用來再啟動SpringBoot時同時啟動其他功能,比如配置,數(shù)據(jù)庫連接等等
然后重寫run方法,在run方法里啟動netty服務器,Server類用@AutoWired直接實例化
package com.safelocate.app;
import com.safelocate.app.nettyServer.NettyServer;
import io.netty.channel.ChannelFuture;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import java.net.InetAddress;
import java.net.InetSocketAddress;
@SpringBootApplication
public class AppApplication implements CommandLineRunner {
@Value("${netty.port}")
private int port;
@Value("${netty.url}")
private String url;
@Autowired
private NettyServer server;
public static void main(String[] args) {
SpringApplication.run(AppApplication.class, args);
}
@Override
public void run(String... args) throws Exception {
InetSocketAddress address = new InetSocketAddress(url,port);
System.out.println("run .... . ... "+url);
server.start(address);
}
}
ok,到這里服務端已經(jīng)寫完,本地我也已經(jīng)測試完,現(xiàn)在需要打包部署服務器,當然這個程序只為練手...
控制臺輸入mvn clean package -D skipTests 然后將jar包上傳服務器,在這之后,需要在騰訊云/阿里云那邊配置好安全組,將之前yml文件里設定的端口的入站
規(guī)則設置好,不然訪問會被拒絕
之后java -jar命令運行,如果需保持后臺一直運行 就用nohup命令,可以看到程序已經(jīng)跑起來了,等待客戶端連接交互
之后就是寫客戶端了,客戶端其實是依葫蘆畫瓢,跟上面類似
Handler
package client;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
public class ClientHandler extends ChannelInboundHandlerAdapter {
@Override
public void channelActive(ChannelHandlerContext ctx) {
System.out.println("ClientHandler Active");
}
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
System.out.println("--------");
System.out.println("ClientHandler read Message:"+msg);
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
cause.printStackTrace();
ctx.close();
}
}
ChannelInitializer
package client;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;
public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {
protected void initChannel(SocketChannel channel) throws Exception {
ChannelPipeline p = channel.pipeline();
p.addLast("decoder", new StringDecoder(CharsetUtil.UTF_8));
p.addLast("encoder", new StringEncoder(CharsetUtil.UTF_8));
p.addLast(new ClientHandler());
}
}
主函數(shù)所在類,即客戶端
package client;
import io.netty.bootstrap.Bootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
public class Client {
static final String HOST = System.getProperty("host", "服務器的IP地址");
static final int PORT = Integer.parseInt(System.getProperty("port", "7000"));
static final int SIZE = Integer.parseInt(System.getProperty("size", "256"));
public static void main(String[] args) throws Exception {
sendMessage("hhhh");
}
public static void sendMessage(String content) throws InterruptedException{
// Configure the client.
EventLoopGroup group = new NioEventLoopGroup();
try {
Bootstrap b = new Bootstrap();
b.group(group)
.channel(NioSocketChannel.class)
.option(ChannelOption.TCP_NODELAY, true)
.handler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast("decoder", new StringDecoder());
p.addLast("encoder", new StringEncoder());
p.addLast(new ClientHandler());
}
});
ChannelFuture future = b.connect(HOST, PORT).sync();
future.channel().writeAndFlush(content);
future.channel().closeFuture().sync();
} finally {
group.shutdownGracefully();
}
}
}
啟動客戶端,這里就是簡單發(fā)送一條"hhhh",可以看到客戶端已經(jīng)收到服務器發(fā)來的信息
 |
然后再看服務端,也有相應的信息打印
總結
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
相關文章
這篇文章主要介紹了java程序員自己的圖片轉文字OCR識圖工具，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-11-11
本文通過實例代碼給大家介紹了java io流文件編碼的方法，非常不錯，具有參考借鑒價值，需要的朋友參考下吧2017-05-05
JavaWeb ServletConfig作用及原理分析講解
ServletConfig對象,叫Servlet配置對象。主要用于加載配置文件的初始化參數(shù)。我們知道一個Web應用里面可以有多個servlet，如果現(xiàn)在有一份數(shù)據(jù)需要傳給所有的servlet使用，那么我們就可以使用ServletContext對象了2022-10-10
這篇文章主要介紹了SpringBoot單點登錄實現(xiàn)過程，單點登錄英文全稱Single?Sign?On，簡稱就是SSO。它的解釋是：在多個應用系統(tǒng)中，只需要登錄一次，就可以訪問其他相互信任的應用系統(tǒng)2022-12-12
這篇文章主要給大家介紹了關于Mybatis延遲加載和緩存的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧2019-02-02
這篇文章主要介紹了springboot中的controller注意事項說明，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
spring?security需求分析與基礎環(huán)境準備教程
這篇文章主要為大家介紹了spring?security需求分析與基礎環(huán)境準備教程，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步2022-03-03
Java經(jīng)驗點滴:處理沒有被捕獲的異常...2006-12-12
這篇文章主要介紹了Java讀寫ini文件代碼示例，分享了相關代碼示例及相關注釋，小編覺得還是挺不錯的，具有一定借鑒價值，需要的朋友可以參考下2018-02-02
這篇文章主要介紹了Java中方法重寫與重載的區(qū)別(面試高頻問點),本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-03-03