资讯专栏INFORMATION COLUMN

【基于netty的安卓实例】以及开发中的若干问题

CNZPH / 444人阅读

摘要:在子线程运行到某个地方,需要向传递消息的时候,创建类的对象,将要传送的对象加入,通过发布传送给主线程,代码示例如下通过发布传送消息,这里的跟中的是同一个对象还有其他的方法在非线程中控制,参见

本周末学习netty长连接,实现了一个netty安卓客户端与服务器连接并发送消息的实例,
代码位置:https://git.oschina.net/lpt20...

主要实现:

引入netty jar包

建立连接客户端代码

> 建立连接

public class HelloClientInitializer extends ChannelInitializer {

    private Handler view;
    public HelloClientInitializer(Handler view){
        this.view=view;
    }
    @Override
    protected void initChannel(SocketChannel ch) throws Exception {
        ChannelPipeline pipeline = ch.pipeline();
        pipeline.addLast("framer", new DelimiterBasedFrameDecoder(8192, Delimiters.lineDelimiter()));
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());

     
        pipeline.addLast("handler", new HelloClientHandler(view));
    }

}

此处获取服务器发送的消息,并对ui进行更改

public class HelloClientHandler extends SimpleChannelInboundHandler {

    private  Handler handler;

    public HelloClientHandler(Handler view) {
        this.handler = view;
    }
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, final String msg) throws Exception {
                Message message = new Message();
                //message.what=11;
                message.obj=msg;
                handler.sendMessage(message);
        System.out.println("Server say : " + msg);
    }

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("Client active ");
        super.channelActive(ctx);
    }

    @Override
    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("Client close ");
        super.channelInactive(ctx);
    }




}

封装连接和断开

public class HelloClient {
    public static String host = "192.168.3.29";
    public static int port = 7946;
    Channel ch;
    private  Handler handler;
    public HelloClient() {
        // TODO Auto-generated constructor stub
    }

    public HelloClient(Handler  handler) {
        // TODO Auto-generated constructor stub
        this.handler=handler;
    }

    /**
     * @param
     * @throws InterruptedException
     * @throws IOException
     */
    public void run() throws InterruptedException, IOException {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group).channel(NioSocketChannel.class).handler(new HelloClientInitializer(handler));
            // 连接服务端
            ch = b.connect(host, port).sync().channel();
            ch.closeFuture().sync(); // 异步关闭,这方法执行完不关闭连接

        } finally {
            // The connection is closed automatically on shutdown.
            group.shutdownGracefully();
        }
    }

    public void sendMSg(String line) {
        /*
         * 向服务端发送在控制台输入的文本 并用"
"结尾 之所以用
结尾 是因为我们在handler中添加了 DelimiterBasedFrameDecoder 帧解码。
         * 这个解码器是一个根据
符号位分隔符的解码器。所以每条消息的最后必须加上
否则无法识别和解码
     */
        ch.writeAndFlush(line + "
");


    }

    public void closeChannel(){
        ch.close();
    }

}

ui主线程,在界面中显示服务器的消息

public class MainActivity extends AppCompatActivity {
    TextView textView;
    HelloClient hc;


     Handler handler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            System.out.println(msg);
            textView.setText(msg.obj.toString());
        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
       textView= (TextView) findViewById(R.id.textview);



        View run = this.findViewById(R.id.run);



        run.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {

                hc=new HelloClient(handler);
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            hc.run();
                        } catch (InterruptedException | IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }

                    }
                }).start();
            }
        });
        View close = this.findViewById(R.id.close);
        close.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                hc.closeChannel();
            }
        });
    }

public Handler getHandler() {
    return handler;
}

    public void setHandler(Handler handler) {
        this.handler = handler;
    }

}

遇到的问题:
ERROR/AndroidRuntime(1222):android.view.ViewRoot$CalledFromWrongThreadException: Only the original thread that created a view hierarchy can touch its views.

如何在handler类中收到服务器消息后更改ui中的控件内容

在安卓中,ui是主线程,子线程无法直接控制ui中的元素,否则会报错,那么我们想在其他线程中控制ui元素应该怎么办呢?
我搜索了网络中的解决办法,其中使用handler比较方便

需要被线程更新UI的Activity 中声明一个android.os.Handler 类的变量,private Handler handler并初始化:

@Override
public void onCreate(Bundle savedInstanceState) {
//其他代码……
handler=new Handler(){
public void handleMessage(Message msg){
     
String message=(String)msg.obj;  //根据message中的信息对主线程的UI进行改动
  //……      
 }
}
};

子线程类中需要获得activity中的handler对象,可以持有表示上下文的Context类对象,实际应用中这个引用就是指向要更新UI的Activity对象,一般声明为: private Context ctx,然后在子线程类构造函数或其它函数中初始化ctx,就可以得到Activity对象中的Handler对象。也可以通过传递handler获取它。

在子线程运行到某个地方,需要向Activity传递消息的时候,创建android.os.Message 类的对象,将要传送的对象加入message ,通过Handler发布传送给主线程,代码示例如下:

String str=message"
Message message = Message.obtain();
message.obj=str;
//通过Handler发布传送消息,handler
handler.sendMessage(message);//这里的handler跟Activity中的handler是同一个对象

还有其他的方法在非ui线程中控制ui,参见http://www.2cto.com/kf/201405...

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/13732.html

相关文章

  • 一位大佬亲身经历总结:简历和面试技巧

    摘要:我觉得了解简历和面试的技巧可以帮助你更好的去学习重要的知识点以及更好地去准备面试以及面试,说实话,我个人觉得这些东西还挺重要的。在本文里,我将介绍我这段时间里更新简历和面试的相关经历。 分享一篇很不错的文章!本文作者曾经写过《Java Web轻量级开发面试教程》和 《Java核心技术及面试指南》这两本书。我觉得了解简历和面试的技巧可以帮助你更好的去学习重要的知识点以及更好地去准备面试以...

    pingan8787 评论0 收藏0
  • 手把手教你基于Netty实现一个基础RPC框架(通俗易懂)

    摘要:是一个分布式服务框架,以及治理方案。手写注意要点手写注意要点基于上文中对于协议的理解,如果我们自己去实现,需要考虑哪些技术呢其实基于图的整个流程应该有一个大概的理解。基于手写实现基于手写实现理解了协议后,我们基于来实现一个通信框架。阅读这篇文章之前,建议先阅读和这篇文章关联的内容。[1]详细剖析分布式微服务架构下网络通信的底层实现原理(图解)[2][年薪60W的技巧]工作了5年,你真的理解N...

    番茄西红柿 评论0 收藏2637
  • 【自己读源码】Netty4.X系列(三) Channel Register

    摘要:我想这很好的解释了中,仅仅一个都这么复杂,在单线程或者说串行的程序中,编程往往是很简单的,说白了就是调用,调用,调用然后返回。 Netty源码分析(三) 前提概要 这次停更很久了,原因是中途迷茫了一段时间,不过最近调整过来了。不过有点要说下,前几天和业内某个大佬聊天,收获很多,所以这篇博文和之前也会不太一样,我们会先从如果是我自己去实现这个功能需要怎么做开始,然后去看netty源码,与...

    darkbug 评论0 收藏0
  • Netty4.x 源码实战系列(一):ServerBootstrap 与 Bootstrap 初探

    摘要:而用于主线程池的属性都定义在中本篇只是简单介绍了一下引导类的配置属性,下一篇我将详细介绍服务端引导类的过程分析。 从Java1.4开始, Java引入了non-blocking IO,简称NIO。NIO与传统socket最大的不同就是引入了Channel和多路复用selector的概念。传统的socket是基于stream的,它是单向的,有InputStream表示read和Outpu...

    BakerJ 评论0 收藏0
  • 基于 Netty 自定义帧高可靠性读取方案

    摘要:完成客户端服务器通信,需要基于协议之上,自定义一套简单的通信协议,其中数据交换方式需要使用自定义帧。输入数据处理器以下为输入数据的第一个处理器,可以保证无论帧经历怎样的粘包拆包,均可以准确提取每一个自定义帧的数据部分。 「博客搬家」 原地址: 简书 原发表时间: 2017-03-26 本文采用 Netty 这一最流行的 Java NIO 框架,作为 Java 服务器通信部分的基础...

    Berwin 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<