Android 网络编程 Socket-低调大师

Android 网络编程 Socket

2017-10-18 814

1.服务端开发

创建一个Java程序

 
        public 
        class 
        MyServer { 
       
        // 定义保存所有的Socket，与客户端建立连接得到一个Socket 
       
        public 
        static 
        List<Socket> socketList = 
        new 
        ArrayList<Socket>(); 
       
        public 
        static 
        void 
        main(String[] args) 
        throws 
        IOException { 
       
        ServerSocket server = 
        new 
        ServerSocket(
        8888
        ); 
       
        while 
        (
        true
        ) { 
       
        System.out.println(
        "start listening port 8888"
        ); 
       
        Socket socket = server.accept(); 
       
        System.out.println(
        "connect succeed."
        ); 
       
        socketList.add(socket); 
       
        //每当客户端连接之后启动一条ServerThread线程为该客户端服务    
       
        new 
        Thread(
        new 
        MyServerRunnable(socket)).start();   
       
        } 
       
        } 
       
        public 
        static 
        class 
        MyServerRunnable 
        implements 
        Runnable { 
       
        // 定义当前线程处理的Socket 
       
        Socket socket = 
        null
        ; 
       
        // 该线程所处理的Socket所对应的输入流 
       
        BufferedReader bufferedReader = 
        null
        ; 
       
        public 
        MyServerRunnable(Socket socket) { 
       
        this
        .socket = socket; 
       
        try 
        { 
       
        // 将服务器端的输入流的数据放入读Buffer中 
       
        bufferedReader = 
        new 
        BufferedReader(
        new 
        InputStreamReader( 
       
        socket.getInputStream())); 
       
        } 
        catch 
        (Exception e) { 
       
        e.printStackTrace(); 
       
        } 
       
        } 
       
        @Override 
       
        public 
        void 
        run() { 
       
        String content = 
        null
        ; 
       
        // 采用循环不断的从Socket中读取客户端发送过来的数据 
       
        while 
        ((content = readFromClient()) != 
        null
        ) { 
       
        // 遍历socketList中的每一个Socket，将读取的内容向每个Socket发送一次 
       
        for 
        (Socket socket : MyServer.socketList) { 
       
        OutputStream outputStream; 
       
        try 
        { 
       
        outputStream = socket.getOutputStream(); 
       
        outputStream.write((
        "Server: " 
        + content + 
        "\n"
        ).getBytes(
        "utf-8"
        )); 
       
        } 
        catch 
        (IOException e) { 
       
        e.printStackTrace(); 
       
        } 
       
        } 
       
        } 
       
        } 
       
        // 定义读取客户端的信息 
       
        public 
        String readFromClient() { 
       
        try 
        { 
       
        return 
        bufferedReader.readLine(); 
       
        } 
        catch 
        (Exception e) { 
       
        e.printStackTrace(); 
       
        } 
       
        return 
        null
        ; 
       
        } 
       
        } 
       
        }

2. 创建一个Android程序

1) Layout

 
        <LinearLayout xmlns:android=
        "http://schemas.android.com/apk/res/android" 
       
        xmlns:tools=
        "http://schemas.android.com/tools" 
       
        android:layout_width=
        "match_parent" 
       
        android:layout_height=
        "match_parent" 
       
        android:gravity=
        "center" 
       
        android:orientation=
        "vertical" 
       
        tools:context=
        ".MainActivity" 
        > 
       
        <TextView 
       
        android:id=
        "@+id/show" 
       
        android:layout_width=
        "wrap_content" 
       
        android:layout_height=
        "wrap_content" 
       
        android:text=
        "显示接收到服务器端数据" 
        /> 
       
        <Button 
       
        android:id=
        "@+id/send" 
       
        android:layout_width=
        "match_parent" 
       
        android:layout_height=
        "wrap_content" 
       
        android:text=
        "发送数据到服务器端" 
        /> 
       
        </LinearLayout>

2)ClientThread类

 
        package 
        com.example.testclient; 
       
        import 
        java.io.BufferedReader; 
       
        import 
        java.io.IOException; 
       
        import 
        java.io.InputStreamReader; 
       
        import 
        java.io.OutputStream; 
       
        import 
        java.net.InetSocketAddress; 
       
        import 
        java.net.Socket; 
       
        import 
        java.net.SocketTimeoutException; 
       
        import 
        android.os.Handler; 
       
        import 
        android.os.Looper; 
       
        import 
        android.os.Message; 
       
        import 
        android.util.Log; 
       
        public 
        class 
        ClientThread 
        implements 
        Runnable { 
       
        private 
        Socket s; 
       
        // 定义向UI线程发送消息的Handler对象 
       
        Handler handler; 
       
        // 定义接收UI线程的Handler对象 
       
        Handler revHandler; 
       
        // 该线程处理Socket所对用的输入输出流 
       
        BufferedReader br = 
        null
        ; 
       
        OutputStream os = 
        null
        ; 
       
        public 
        ClientThread(Handler handler) { 
       
        this
        .handler = handler; 
       
        } 
       
        @Override 
       
        public 
        void 
        run() { 
       
        s = 
        new 
        Socket(); 
       
        Log.d(
        "111111111111"
        , 
        "@@@@@@@@@@@@@@@@@@@@"
        ); 
       
        try 
        { 
       
        //192.168.0.26 为PC IP地址。<br><br>          s.connect(new InetSocketAddress("192.168.0.26", 8888), 5000); 
       
        Log.d(
        "111111111111"
        , 
        "$$"
        ); 
       
        br = 
        new 
        BufferedReader(
        new 
        InputStreamReader(s.getInputStream())); 
       
        os = s.getOutputStream(); 
       
        // 启动一条子线程来读取服务器相应的数据 
       
        new 
        Thread() { 
       
        @Override 
       
        public 
        void 
        run() { 
       
        String content = 
        null
        ; 
       
        // 不断的读取Socket输入流的内容 
       
        try 
        { 
       
        while 
        ((content = br.readLine()) != 
        null
        ) { 
       
        // 每当读取到来自服务器的数据之后，发送的消息通知程序 
       
        // 界面显示该数据 
       
        Message msg = 
        new 
        Message(); 
       
        msg.what = 
        0x123
        ; 
       
        msg.obj =  content; 
       
        handler.sendMessage(msg); 
       
        Log.d(
        "111111111111"
        , content); 
       
        } 
       
        } 
        catch 
        (IOException io) { 
       
        io.printStackTrace(); 
       
        } 
       
        } 
       
        }.start(); 
       
        // 为当前线程初始化Looper 
       
        Looper.prepare(); 
       
        // 创建revHandler对象 
       
        revHandler = 
        new 
        Handler() { 
       
        @Override 
       
        public 
        void 
        handleMessage(Message msg) { 
       
        // 接收到UI线程的中用户输入的数据 
       
        if 
        (msg.what == 
        0x345
        ) { 
       
        // 将用户在文本框输入的内容写入网络 
       
        try 
        { 
       
        os.write((
        "Client" 
        + msg.obj.toString() + 
        "\r\n"
        ) 
       
        .getBytes(
        "utf-8"
        )); 
       
        } 
        catch 
        (Exception e) { 
       
        e.printStackTrace(); 
       
        } 
       
        } 
       
        } 
       
        }; 
       
        // 启动Looper 
       
        Looper.loop(); 
       
        } 
        catch 
        (SocketTimeoutException e) { 
       
        Message msg = 
        new 
        Message(); 
       
        msg.what = 
        0x123
        ; 
       
        msg.obj = 
        "网络连接超时！"
        ; 
       
        handler.sendMessage(msg); 
       
        }
        catch 
        (IOException e) { 
       
        // TODO Auto-generated catch block 
       
        e.printStackTrace(); 
       
        } 
       
        } 
       
        }

3. MainActivity

 
        public 
        class 
        MainActivity 
        extends 
        Activity { 
       
        Handler handler; 
       
        // 定义与服务器通信的子线程 
       
        ClientThread clientThread; 
       
        TextView show; 
       
        Button send; 
       
        @Override 
       
        protected 
        void 
        onCreate(Bundle savedInstanceState) { 
       
        super
        .onCreate(savedInstanceState); 
       
        setContentView(R.layout.activity_main); 
       
        show = (TextView) 
        this
        .findViewById(R.id.show); 
       
        send = (Button) 
        this
        .findViewById(R.id.send); 
       
        send.setOnClickListener(
        new 
        View.OnClickListener() { 
       
        @Override 
       
        public 
        void 
        onClick(View arg0) { 
       
        // TODO Auto-generated method stub 
       
        try 
        { 
       
        // 当用户按下按钮之后，将用户输入的数据封装成Message 
       
        // 然后发送给子线程Handler 
       
        Message msg = 
        new 
        Message(); 
       
        msg.what = 
        0x345
        ; 
       
        msg.obj = 
        "Android 网络编程--Socket通信编程"
        ; 
       
        clientThread.revHandler.sendMessage(msg); 
       
        } 
        catch 
        (Exception e) { 
       
        e.printStackTrace(); 
       
        } 
       
        } 
       
        }); 
       
        handler = 
        new 
        Handler() { 
       
        @Override 
       
        public 
        void 
        handleMessage(Message msg) { 
       
        // 如果消息来自子线程 
       
        if 
        (msg.what == 
        0x123
        ) { 
       
        // 将读取的内容追加显示在文本框中 
       
        show.append(
        "\n" 
        + msg.obj.toString()); 
       
        show.setTextSize(
        50
        ); 
       
        } 
       
        } 
       
        }; 
       
        clientThread = 
        new 
        ClientThread(handler); 
       
        // 客户端启动ClientThread线程创建网络连接、读取来自服务器的数据 
       
        new 
        Thread(clientThread).start(); 
       
        } 
       
        }

参考：http://blog.csdn.net/thanksgining/article/details/43561053

本文转自Work Hard Work Smart博客园博客，原文链接：http://www.cnblogs.com/linlf03/p/5124061.html，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/359167

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Basic4android - 使用Basic开发Android应用

Basic4android，拥有独立的IDE，强大的libary覆盖android SDK，编译生成原生apk包及java代码。支持所见即所得的layout，让你只关注业务逻辑以快速开发。环境安装 1) 安装Basic4android，官方网站有免费版下载，收费版本功能更全 2) 真机上安装B4A-Bridge，连接真机调试用，模拟器不需要 3) 安装JDK 4) 安装Android SDK (路径不要有空格) 配置SDK，下载所需要的包 (我这里选择的是platform-tools,2.2 sdk,usb) 5) 配置Basic4android中的android sdk路径和jdk路径 Tools -> Configure Paths 模拟器配置 1) 配置AVD 可以New一个新的virtual device，选中，start启动模拟器 Hello word 1) 启动IDE，加下面一行代码，保存项目，project/package name设置名子(d4a.开头小写) Sub Activity_Create(FirstTime As Boolean) Msgbox("h...

2017-10-19

1044

别再设计你的应用界面了，在用户体验上下点功夫吧

本文讲的是别再设计你的应用界面了，在用户体验上下点功夫吧，这篇文章是我们新发布的界面指南的一部分混乱的过程往往导致混乱的结果八个月前，在一个机构工作一段时间后，我终于决定给自己一个新的挑战。现在可以很自豪地说，我加入 BlaBlaCar 的设计团队。在刚到这家公司的前几周时，我是真的对他们的工作方式有些无语。他们的工具仅仅是一个空空的 Sketch 文件，一块儿白板和两部用来给应用做测试截屏的手机。 BlaBlaCar 的设计师们所使用的工具: 一个空的 Sketch 文件和两部测试机。他们通过直接向 Sketch 里导入截屏的方式来设计一个页面或流程——裁剪截图，直接在截图上编辑，遮盖或是创建一些新的元素，也有时候从之前完成的文件中拿点儿什么之前完成的组件...从始至终都能听到他们的自言自语，比如，“边距多少是合适的？”，“这个

2017-10-19

644

发表评论

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。