devbox
我家自动化
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用Netty与Android构建简单C/S消息服务_netty server 怎么控制android

作者：我家自动化 | 2024-02-28 18:02:52

赞

踩

netty server 怎么控制android

使用Netty 构建简单C/S消息服务

Server

首先记得引入nettycompile 'io.netty:netty-all:4.1.13.Final'

  1. public class Server {
  2.     private static final int PORT = 8999;
  3.  
  4.     public static void main(String[] args) {
  5.         // NioEventLoopGroup is a multithreaded event loop that handles I/O operation.
  6.         EventLoopGroup bossGroup = new NioEventLoopGroup(); // 用于处理客户端的连接请求
  7.         EventLoopGroup workerGroup = new NioEventLoopGroup(); // 用于处理与各个客户端连接的IO操作
  8.  
  9.         // ServerBootstrap is a helper class that sets up a server.
  10.         ServerBootstrap serverBootstrap = new ServerBootstrap();
  11.         serverBootstrap.group(bossGroup, workerGroup)
  12.                 .channel(NioServerSocketChannel.class) // 使用Java Nio的Selector来处理新连接接入
  13.  
  14.                 // ChannelInitializer是一个特殊的Handler用来帮助用户配置新Channel，一般用于在channelPipeline中新建channelHandler
  15.                 .childHandler(new ChannelInitializer<SocketChannel>() {
  16.                     @Override
  17.                     protected void initChannel(SocketChannel ch) throws Exception {
  18.                         ch.pipeline().addLast(new EchoServerHandler());
  19.                     }
  20.                 })
  21.                 .option(ChannelOption.SO_BACKLOG, 128)  // 对应bossGroup
  22.                 .childOption(ChannelOption.SO_KEEPALIVE, true); // 对应workerGroup
  23.         try {
  24.             ChannelFuture channelFuture = serverBootstrap.bind(PORT).sync();    // 等待接入
  25.  
  26.             // Wait until the server socket is closed.
  27.             // In this example, this does not happen, but you can do that to gracefully
  28.             // shut down your server.
  29.             channelFuture.channel().closeFuture().sync();
  30.         } catch (InterruptedException e) {
  31.             e.printStackTrace();
  32.         } finally {
  33.             workerGroup.shutdownGracefully();
  34.             bossGroup.shutdownGracefully();
  35.         }
  36.     }
  37. }

ChannelInboundHandlerAdapter负责处理连接建立，收到消息。

  1. public class EchoServerHandler extends ChannelInboundHandlerAdapter {
  2.     @Override
  3.     public void channelActive(ChannelHandlerContext ctx) throws Exception {
  4.         super.channelActive(ctx);
  5.         System.out.println("connected from:" + ctx.channel().remoteAddress());
  6.     }
  7.  
  8.     @Override
  9.     public void channelInactive(ChannelHandlerContext ctx) throws Exception {
  10.         super.channelInactive(ctx);
  11.     }
  12.  
  13.     @Override
  14.     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
  15.         ByteBuf byt = (ByteBuf) msg;
  16.         byte[] bytesSrc = new byte[byt.readableBytes()];
  17.         byt.readBytes(bytesSrc);
  18.         String data = new String(bytesSrc);
  19.         System.out.println("received:" + data + " from:" + ctx.channel().remoteAddress());
  20.         String response = "response: " + data;
  21.  
  22.         ByteBuf responseBuf = ctx.alloc().buffer(response.length());
  23.         responseBuf.writeBytes(response.getBytes());
  24.         ctx.channel().writeAndFlush(responseBuf);
  25.         byt.release();  // 释放资源
  26.     }
  27.  
  28.     @Override
  29.     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
  30.         cause.printStackTrace();
  31.         ctx.close();
  32.     }
  33. }

Client

  1. public class MainActivity extends AppCompatActivity {
  2.     private EditText mIpEt;
  3.     private EditText mPortEt;
  4.     private Button mConnBtn;
  5.     private TextView mScreenTv;
  6.     private EditText mInputEt;
  7.     private Button mSendBtn;
  8.  
  9.     private SocketThread mSocketThread;
  10.     private static Handler mMainHandler;
  11.  
  12.     public static final int MSG_CONNECT = 0x001;
  13.     public static final int MSG_RECEIVE = 0x002;
  14.     public static final int MSG_SEND = 0x003;
  15.  
  16.     public static final String DATA_RECEIVE = "data_receive";
  17.     public static final String DATA_SEND = "data_send";
  18.  
  19.     @Override
  20.     protected void onCreate(@Nullable Bundle savedInstanceState) {
  21.         super.onCreate(savedInstanceState);
  22.         setContentView(R.layout.activity_main);
  23.  
  24.         mIpEt = findViewById(R.id.main_ip_et);
  25.         mPortEt = findViewById(R.id.main_port_et);
  26.         mConnBtn = findViewById(R.id.main_connect_btn);
  27.         mScreenTv = findViewById(R.id.main_screen_tv);
  28.         mInputEt = findViewById(R.id.main_input_et);
  29.         mSendBtn = findViewById(R.id.main_send_btn);
  30.  
  31.         // defalut value. Change it to your own server ip
  32.         mIpEt.setText("172.16.62.65");
  33.         mPortEt.setText("8999");
  34.  
  35.         mConnBtn.setOnClickListener(new View.OnClickListener() {
  36.             @Override
  37.             public void onClick(View v) {
  38.                 String ip = mIpEt.getText().toString();
  39.                 String port = mPortEt.getText().toString();
  40.                 if (TextUtils.isEmpty(ip) || TextUtils.isEmpty(port)) {
  41.                     Toast.makeText(MainActivity.this, "ip or port is null", Toast.LENGTH_SHORT).show();
  42.                 } else {
  43.                     connectToServer(ip, Integer.valueOf(port));
  44.                 }
  45.             }
  46.         });
  47.  
  48.         mSendBtn.setOnClickListener(new View.OnClickListener() {
  49.             @Override
  50.             public void onClick(View v) {
  51.                 String data = mInputEt.getText().toString();
  52.                 if (!TextUtils.isEmpty(data)) {
  53.                     mSocketThread.sendMessage(data);
  54.                 }
  55.             }
  56.         });
  57.  
  58.         // TODO handler may cause memory leaks
  59.         mMainHandler = new Handler() {
  60.             @Override
  61.             public void handleMessage(Message msg) {
  62.                 switch (msg.what) {
  63.                     case MSG_CONNECT:
  64.                         Toast.makeText(MainActivity.this, "Connect to Server Success", Toast.LENGTH_SHORT).show();
  65.                         mConnBtn.setText("Connected");
  66.                         mConnBtn.setEnabled(false);
  67.                         break;
  68.                     case MSG_RECEIVE:
  69.                         Bundle data = msg.getData();
  70.                         String dataStr = data.getString(DATA_RECEIVE);
  71.                         CharSequence originData = mScreenTv.getText();
  72.                         String result = originData + "\n" + dataStr;
  73.                         mScreenTv.setText(result);
  74.                         break;
  75.                 }
  76.             }
  77.         };
  78.     }
  79.  
  80.  
  81.     private void connectToServer(String ip, int port) {
  82.         mSocketThread = new SocketThread(ip, port);
  83.         mSocketThread.start();
  84.     }
  85.  
  86.     private static class SocketThread extends Thread {
  87.         private Channel mChannel;
  88.         private String mIp;
  89.         private int mPort;
  90.         private SendThread mSendThread;
  91.  
  92.         public SocketThread(String ip, int port) {
  93.             this.mIp = ip;
  94.             this.mPort = port;
  95.         }
  96.  
  97.         @Override
  98.         public void run() {
  99.             EventLoopGroup eventLoopGroup = new NioEventLoopGroup();
  100.             Bootstrap clientBootStrap = new Bootstrap();
  101.             clientBootStrap.group(eventLoopGroup)
  102.                     .channel(NioSocketChannel.class)
  103.                     .option(ChannelOption.TCP_NODELAY, true)
  104.                     .handler(new ChannelInitializer<SocketChannel>() {
  105.                         @Override
  106.                         protected void initChannel(SocketChannel ch) throws Exception {
  107.                             ch.pipeline().addLast(new EchoClientHandler(mMainHandler));
  108.                         }
  109.                     });
  110.  
  111.             try {
  112.                 // Start the client.
  113.                 ChannelFuture future = clientBootStrap.connect(mIp, mPort).sync();
  114.                 mChannel = future.channel();
  115.                 mSendThread = new SendThread(mChannel);
  116.                 mSendThread.start();
  117.  
  118.                 // Wait until the connection is closed.
  119.                 mChannel.closeFuture().sync();
  120.             } catch (InterruptedException e) {
  121.                 e.printStackTrace();
  122.             } finally {
  123.                 eventLoopGroup.shutdownGracefully();
  124.             }
  125.         }
  126.  
  127.         public void sendMessage(String data) {
  128.             Handler socketHandler = mSendThread.getSocketHandler();
  129.             Message message = socketHandler.obtainMessage();
  130.             message.what = MSG_SEND;
  131.             Bundle bundle = new Bundle();
  132.             bundle.putString(DATA_SEND, data);
  133.             message.setData(bundle);
  134.             socketHandler.sendMessage(message);
  135.         }
  136.  
  137.     }
  138.  
  139.     private static class SendThread extends Thread {
  140.         private Handler mSocketHandler;
  141.         private Channel mChannel;
  142.  
  143.         public SendThread(Channel channel) {
  144.             mChannel = channel;
  145.         }
  146.  
  147.         @Override
  148.         public void run() {
  149.             // init child thread handler
  150.             if (mSocketHandler == null) {
  151.                 Looper.prepare();
  152.                 mSocketHandler = new Handler(Looper.myLooper()) {
  153.                     @Override
  154.                     public void handleMessage(Message msg) {
  155.                         switch (msg.what) {
  156.                             case MSG_SEND:
  157.                                 String data = msg.getData().getString(DATA_SEND);
  158.                                 ByteBuf byteBuf = Unpooled.buffer(data.length());   //使用非池化Buffer去申请内存，这里待优化
  159.                                 byteBuf.writeBytes(data.getBytes());
  160.                                 mChannel.writeAndFlush(byteBuf);
  161.                                 break;
  162.                         }
  163.                     }
  164.                 };
  165.             }
  166.             Looper.loop();
  167.         }
  168.  
  169.         public Handler getSocketHandler() {
  170.             return mSocketHandler;
  171.         }
  172.     }
  173. }

ChannelInboundHandlerAdapter实现代码，用于处理连接建立、收到消息。

  1. public class EchoClientHandler extends ChannelInboundHandlerAdapter {
  2.     private Handler mMainHandler;
  3.  
  4.     public EchoClientHandler(Handler handler) {
  5.         mMainHandler = handler;
  6.     }
  7.     @Override
  8.     public void channelActive(ChannelHandlerContext ctx) throws Exception {
  9.         super.channelActive(ctx);
  10.         mMainHandler.sendEmptyMessage(MainActivity.MSG_CONNECT);
  11.     }
  12.  
  13.     @Override
  14.     public void channelInactive(ChannelHandlerContext ctx) throws Exception {
  15.         super.channelInactive(ctx);
  16.     }
  17.  
  18.     @Override
  19.     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
  20.         ByteBuf byt = (ByteBuf) msg;
  21.         byte[] bytesSrc = new byte[byt.readableBytes()];
  22.         byt.readBytes(bytesSrc);
  23.         String data = new String(bytesSrc);
  24.         Message message = mMainHandler.obtainMessage();
  25.         message.what = MainActivity.MSG_RECEIVE;
  26.         Bundle extra = new Bundle();
  27.         extra.putString(MainActivity.DATA_RECEIVE, data);
  28.         message.setData(extra);
  29.         mMainHandler.sendMessage(message);
  30.  
  31.         byt.release();  // 释放资源
  32.     }
  33.  
  34.     @Override
  35.     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
  36.         cause.printStackTrace();
  37.         ctx.close();
  38.     }
  39. }

Layout

  1. <?xml version="1.0" encoding="utf-8"?>
  2. <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
  3.     android:layout_width="match_parent"
  4.     android:layout_height="match_parent"
  5.     android:orientation="vertical"
  6.     android:layout_margin="15dp">
  7.  
  8.     <EditText
  9.         android:id="@+id/main_ip_et"
  10.         android:layout_width="match_parent"
  11.         android:layout_height="wrap_content"
  12.         android:hint="ip address"/>
  13.  
  14.     <EditText
  15.         android:id="@+id/main_port_et"
  16.         android:layout_width="match_parent"
  17.         android:layout_height="wrap_content"
  18.         android:hint="port"
  19.         android:inputType="number"/>
  20.  
  21.     <Button
  22.         android:id="@+id/main_connect_btn"
  23.         android:layout_width="wrap_content"
  24.         android:layout_height="wrap_content"
  25.         android:layout_gravity="center"
  26.         android:text="Connect"/>
  27.  
  28.     <EditText
  29.         android:id="@+id/main_input_et"
  30.         android:layout_width="match_parent"
  31.         android:layout_height="wrap_content"
  32.         android:hint="message to server"/>
  33.  
  34.     <Button
  35.         android:id="@+id/main_send_btn"
  36.         android:layout_width="wrap_content"
  37.         android:layout_height="wrap_content"
  38.         android:layout_gravity="center"
  39.         android:text="Send"/>
  40.  
  41.     <ScrollView
  42.         android:layout_width="match_parent"
  43.         android:layout_height="match_parent"
  44.         android:layout_marginTop="10dp">
  45.         <TextView
  46.             android:id="@+id/main_screen_tv"
  47.             android:layout_width="match_parent"
  48.             android:layout_height="wrap_content"
  49.             android:text="received message will be shown here"/>
  50.     </ScrollView>
  51.  
  52. </LinearLayout>

Run


声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/160739
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号