首页 > 编程技术 > android

解决Android上用javascript对webview的password控件赋值问题

发布时间:2016-9-20 19:58

password控件是一个密码控件了我们在登录时密码都是使用这个控件了,下面小编为各位介绍解决Android上用javascript对webview的password控件赋值问题,希望对各位有帮助。

在cnblogs的android客户端开中使用webview模拟登录,这样就需要将用户输入的用户名和密码传到webview上然后提交,这个过程在mx3的flyme3和flyme4上测试一切正常,然而在我的htcG12上(用的miui4),和三星note2上都报错。

报错的代码为:

 代码如下 复制代码


public void LoginByPassword(String username, String password){
        mCurrentRT = EnumRequestType.LoginFinish;
        final String strJS = String.format("javascript:document.getElementById('tbUserName').value='%s';document.getElementById('tbPassword').value='%s';document.getElementById('form1').submit();", username, password);
        mWeb.post(new Runnable() {
            public void run() {
                mWeb.loadUrl(strJS);
            }
        });
    }

mWeb.loadUrl(strJS);时报错了,报错的内容为“android.view.WindowManager$BadTokenException: Unable to add window -- token null is not for an application”。
解决办法,是对mWeb的settings进行设置不保存密码“settings.setSavePassword(false);”代码如下:

 

 代码如下 复制代码
@SuppressLint({ "SetJavaScriptEnabled"})
private void initialWeb(){
    WebSettings settings = mWeb.getSettings();
    settings.setSavePassword(false);
    settings.setSaveFormData(false);
    settings.setJavaScriptEnabled(true);
    settings.setBlockNetworkImage(true);
    mWeb.addJavascriptInterface(new JSInterface(), "IFObj");
    mWeb.setWebViewClient(mBlogWebClient);
}

就此,原因找到了,不过“Unable to add window -- token null is not for an application”的错误,并不都是这个导致的。

Android应用程序调试和运行,是Android开发的一个重点,因为开发和调试不在同一设备,一般是安装虚拟机。本教程我们来学习如何在真实的设备上(比如手机)调试运行Android应用。

在本教程中,我们将使用Windows 64位平台上的下列工具:

JDK1.7

Eclipse 4.2 Juno

Sony Xperia Tipo

为了在真实设备上调试和运行应用,大体上需要遵循以下步骤:

如果你使用的是Android开发手机(ADP),例如Nexus One或者Nexus S,下载Google的USB驱动。

如果你使用的是其他Android设备,如索尼、LG、HTC、那么下载对应OEM的USB驱动。

在手机上开启USB调试。

将设备连到电脑。

使用adb.exe devices命令确认设备已经成功连接。

设置Eclipse,以便手动选择运行应用的目标设备。

1. 下载USB驱动

如果您使用的是Android开发手机(ADP)的设备,你只需要打开Android SDK管理器然后安装谷歌的USB驱动程序。

 

google-usb-driver

 

如果你使用的是其他的Android设备,可以按照官方的Android USB驱动程序指南,下载自己的设备驱动程序。

正如前面提到的,我将使用索尼的Xperia Tipo。如果您使用的是索尼的设备,可以在索尼手机页面找到合适的驱动程序。在我的例子中,当手机插到电脑上时,就会提示需要安装索尼PC伴侣。

 

phone-companion1

 

这将把所有手机连接到电脑需要的驱动程序都安装上,包括用于Android调试的USB驱动程序。我认为这应该是最现代化的智能手机的案例。如果你遇到任何问题,可以随时访问厂商的网页下载驱动程序。安装完驱动程序后,可能需要重新启动计算机。

2. 在设备上启用USB调试

为了在真实设备上运行Android应用,需要在手机上开启USB调试功能。

进入 “设置”

 

settings

 

“开发者选项”

 

dev-options

 

“USB调试”。

 

usb-debugging

 

3. 把设备连接到电脑上

在本步骤中,必须将手机连接到PC,并确认它能被系统正确识别。如果这一步工作正常,这意味着USB驱动程序工作正常。

如果你的手机已经连接,打开命令提示符并进入到Android SDK的安装文件夹中,进入 platform-tools目录。在该文件夹中有很多Android的命令行工具。

粘贴以下命令:

1adb.exe devices

 

devices

 

正如上图看到的,设备已成功连接,并被分配ID BX903DMU63。太好了!

4. Eclipse 开发设置

如果你已经开发了一段时间的Android应用程序,可能你一直在使用Android模拟器。 Eclipse中默认的设置是在Android虚拟设备上部署应用程序。因此,我们要对其进行配置,允许手动选择,我们希望应用程序运行在手动选择的设备上。其中的一个选项必须是我们的真实设备。

在Eclipse中选择“运行->运行配置”。然后从左边列表中选择想要运行的Android项目。单击“目标”选项卡。选择选项“始终提示选择设备”。另外,您可以选择“启动所有兼容的设备/AVD”。此选项将在所有可用的Android设备上,包括模拟器和真实设备,在同一时间运行您的项目。

在本教程中我将使用一个工作区中已有的Android项目,它是一个简单的Android进度条的例子。

 

prompt-to-pick-device

 

5. 运行项目

现在,当运行Android项目时会提示你选择一个设备。选中“选择一个运行中的Android设备”,然后选择自己的设备。

 

select-real-device

 

现在让我们看看我们的应用在真实设备上是什么样子的。这是主画面:

 

main-screen

 

当我们轻点按钮:

 

screen

 

就是这样!

这就是关于如何在Android真实设备上调试应用的Android教程。

上一教程我们讲了Android基于Protobuf的Socket通讯开发,本教程我们来讲讲基于protobuf的Android socket通信的实例。这样可以让大家更深入的学习。

关于Protobuf的获取、用法见这篇文章:http://www.111cn.net/sj/android/71936.htm


下面直接贴我的实例,

一、服务端:


基于protobuf的Android socket通信的实例教程

关键代码Main.Java

 代码如下 复制代码
package com.jerome.test; 
 
public class Main { 
 
    public static void main(String[] args) { 
        new Thread(new DealThread()).start(); 
    } 
}


DealThread.Java

package com.jerome.test; 
 
import java.io.IOException; 
import java.io.InputStream; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
import pbmsg.UserProto.User; 
 
public class DealThread implements Runnable { 
 
    ServerSocket sSocket = null; 
 
    @Override 
    public void run() { 
        try { 
            sSocket = new ServerSocket(12345); 
            while (true) { 
                Socket socket = sSocket.accept(); 
                InputStream inputstream = socket.getInputStream(); 
 
                byte len[] = new byte[1024]; 
                int count = inputstream.read(len); 
                byte[] temp = new byte[count]; 
                for (int i = 0; i < count; i++) { 
                    temp[i] = len[i]; 
                } 
 
                User user = User.parseFrom(temp); 
                System.out.println(user.getID()); 
                System.out.println(user.getUserName()); 
                System.out.println(user.getPassword()); 
                 
 
                User uproto = User.newBuilder().setID(88888888) 
                        .setPassword("654321").setUserName("zwq").build(); 
                uproto.writeTo(socket.getOutputStream()); 
            } 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } 
 
    } 
 




二、客户端

 代码如下 复制代码

package com.jerome.test; 
 
import java.io.IOException; 
import java.io.InputStream; 
import java.net.Socket; 
import java.net.UnknownHostException; 
 
import pbmsg.UserProto.User; 
import android.app.Activity; 
import android.os.Bundle; 
import android.util.Log; 
import android.view.View; 
import android.view.View.OnClickListener; 
import android.widget.Button; 
import android.widget.TextView; 
 
public class MainActivity extends Activity { 
 
    Button button = null; 
    TextView text = null; 
    Socket socket = null; 
 
    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
        super.onCreate(savedInstanceState); 
        setContentView(R.layout.activity_main); 
 
        button = (Button) findViewById(R.id.button); 
        text = (TextView) findViewById(R.id.text); 
        button.setOnClickListener(new OnClickListener() { 
 
            @Override 
            public void onClick(View v) { 
                //网络请求必须要在线程中完成; 
                 
                //发送线程 
                new Thread() { 
                    public void run() { 
                        sendText(); 
                    } 
                }.start(); 
 
                //接受线程 
                new Thread() { 
                    public void run() { 
                        getText(); 
                    } 
                }.start(); 
            } 
 
        }); 
    } 
 
    private void sendText() { 
        try { 
            socket = new Socket("192.168.7.119", 12345); 
            User uproto = User.newBuilder().setID(147258369) 
                    .setPassword("123456").setUserName("jerome").build(); 
            uproto.writeTo(socket.getOutputStream()); 
 
            //也可以在这儿接受流,也可以启动新线程用于接受 
//          InputStream inputstream = socket.getInputStream(); 
//          byte len[] = new byte[1024]; 
//          int count = inputstream.read(len); 
//          byte[] temp = new byte[count]; 
//          for (int i = 0; i < count; i++) { 
//              temp[i] = len[i]; 
//          } 
 
//          User user = User.parseFrom(temp); 
//          Log.i("zwq", "Id:" + user.getID() + "____" + user.getUserName() + "____" + user.getPassword()); 
        } catch (UnknownHostException e) { 
            e.printStackTrace(); 
        } catch (IOException e) { 
            e.printStackTrace(); 
        } finally { 
        } 
    } 
 
    private void getText() { 
        while (true) { 
            try { 
                if (null != socket) { 
                    InputStream inputStream = socket.getInputStream(); 
                    if (null != inputStream) { 
                        byte len[] = new byte[1024]; 
                        int count = inputStream.read(len); 
                        byte[] temp = new byte[count]; 
                        for (int i = 0; i < count; i++) { 
                            temp[i] = len[i]; 
                        } 
 
                        User user = User.parseFrom(temp); 
                        Log.i("zwq","Id:" + user.getID() + "____"+ user.getUserName() + "____"+ user.getPassword()); 
                    } 
                } 
            } catch (Exception e) { 
                e.printStackTrace(); 
            } 
        } 
    } 

 

本教程为您介绍Protobuf实现Android Socket通讯开发,Protocol buffers是一种编码方法构造的一种有效而可扩展的格式的数据。谷歌使用其内部几乎RPC协议和文件格式的所有协议缓冲区。

protobuf 适用的语言

正宗(Google 自己内部用的)的protobuf支持三种语言:Java 、c++和Pyton,很遗憾的是并不支持.Net 或者 Lua 等语言,但社区的力量是不容忽视的,由于protobuf确实比Json、XML有速度上的优势和使用的方便,并且可以做到向前兼容、向后兼容等众多特点,所以protobuf社区又弄了个protobuf.net的组件并且还支持众多语言,详细可以看这个链接:http://code.google.com/p/protobuf/wiki/ThirdPartyAddOns,具体某种语言的使用请各自对号入座,本篇只是讲使用android 与c++服务器通讯(测试过)或者与PC 通讯,使用java与C#之间互相通讯方面的DEMO,方面读者做参考。

 
使用protobuf协议

定义protobuf协议

定义protobuf协议必须创建一个以.proto为后缀的文件,以本篇为例,本篇创建了一个叫msg.proto的消息文件,内容如下:

 代码如下 复制代码

package msginfo;

message CMsg
{
    required string msghead = 1;
    required string msgbody = 2;
}

message CMsgHead
{
    required int32 msglen = 1;
    required int32 msgtype = 2;
    required int32 msgseq = 3;
    required int32 termversion = 4;
    required int32 msgres = 5;
    required string termid = 6;
}

message CMsgReg
{
    optional int32 area = 1;
    optional int32 region = 2;
    optional int32 shop = 3;
    optional int32 ret = 4;
    optional string termid = 5[defalut="12345"];
}

message CMsgLogin
{
    optional int32 ret = 1;
}

message CMsgLogout
{
    optional int32 ret = 1;
}


package在Java里面代表这个文件所在的包名,在c#里面代表该文件的命名空间,message代表一个类,
required 代表该字段必填,optional 代表该字段可选,并可以为其设置默认值,默认值格式 :[defalut=字符串就是"123" ,整型就是 123]。

如何编译该proto文件

java或android 使用的编译方法

正宗的proto可以在Linux下编译也有提供win版编译,由于Linux下编译要配置什么g++呀,之类的有点麻烦,之前做的步骤都忘得差不多,那还是回到win版编译吧,而net 版则是需要在win版下编译。

正宗google 的protobuf 下载列表请参照:http://code.google.com/p/protobuf/downloads/list  ,选择其中的win版本下载。解压后会得到一个protoc.exe 文件,此时就可以开始编译了,先以java 为例,编译的步骤如下:

 
cmd 打开命令工具

以我电脑为例,该exe 文件我放在F:protoc 目录下,先cd 到该目录 cd F:protoc
Android基于Protobuf的Socket通讯开发教程
再次进入目录后会发现该目录多了一个文件夹,即以该proto的package命名的的目录,会产生一个Msg.java的文件,这时这个文件就可以使用到我们的java或者 android 工程了。
最后一步下载一个protobuf-java-2.3.0.jar的jar 包引用到你的java和android工程 里面,OK。可以使用你的protobuf了。如下图:
Android基于Protobuf的Socket通讯开发教程

 

c#或者以后的Windows Phone 7 使用的编译方法:

.net 版的protobuf来源于proto社区,有两个版本。一个版本叫protobuf-net,官方站点:http://code.google.com/p/protobuf-net/  写法上比较符合c#一贯的写法。另一个版本叫protobuf-csharp-sport ,
官方站点:http://code.google.com/p/protobuf-csharp-port/ 写法上跟java上的使用极其相似,比较遵循Google 的原生态写法,所以做跨平台还是选择第二版本吧。因为你会发现几乎和java的写法没啥两样,本篇也是使用这个版本。

 

进入该站点,下载你要的win版。 编译步骤如下:

    将刚才你的proto文件放在你解压出来的目录与protoc.exe 、ProtoGen.exe、ProtoGen.exe.config放于一起。其他文件可以删除或者 备份。
    还是打开命令行,定位于对应的目录里面,你放proto文件的目录里面。
    输入:protoc --descriptor_set_out=msg.protobin --include_imports msg.proto        
    msg.protobin是要生成的prtobobin文件,可以使用这个bin文件生成cs文件
    再输入protogen msg.protobin  使用该bin文件生成cs文件,这样你就可以得到该 msg.cs 的CSharp版文件了,同时在VS里面使用要引入Google.ProtocolBuffers.dll。为了方便你可以将其做成一个批处理文件代码如下:

 代码如下 复制代码
    echo on
    protoc --descriptor_set_out=msg.protobin --include_imports msg.proto
    protogen msg.protobin  


将其另存为.bat文件即可

使用protobuf编译后的文件来进行socket连接

android 与PC

android 做为客户端向PC的Java服务端发送数据,服务端得到数据进行解析,并打印出来 。

客户端代码:

 代码如下 复制代码

package net.testSocket;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.net.UnknownHostException;

import socket.exception.SmsClientException;
import socket.exception.SmsObjException;

import msginfo.Msg.CMsg;
import msginfo.Msg.CMsgHead;
import msginfo.Msg.CMsgReg;
import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

import com.google.protobuf.InvalidProtocolBufferException;

//客户端的实现
public class TestSocket extends Activity {
    private TextView text1;
    private Button but1;
    Socket socket = null;

    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        // Thread desktopServerThread=new Thread(new AndroidServer());
        // desktopServerThread.start();

        setContentView(R.layout.main);

        text1 = (TextView) findViewById(R.id.text1);
        but1 = (Button) findViewById(R.id.but1);

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

                // edit1.setText("");
                // Log.e("dddd", "sent id");
                // new Thread() {
                // public void run() {
                try {
                    // socket=new Socket("192.168.1.102",54321);
                    //socket = new Socket("192.168.1.110", 10527);
                     socket = new Socket("192.168.1.116", 12345);
                    //得到发送消息的对象
                    //SmsObj smsobj = new SmsObj(socket);
                   
                    //设置消息头和消息体并存入消息里面
                    // head
                    CMsgHead head = CMsgHead.newBuilder().setMsglen(5)
                            .setMsgtype(1).setMsgseq(3).setTermversion(41)
                            .setMsgres(5).setTermid("11111111").build();

                    // body
                    CMsgReg body = CMsgReg.newBuilder().setArea(22)
                            .setRegion(33).setShop(44).build();

                    // Msg
                    CMsg msg = CMsg.newBuilder()
                            .setMsghead(head.toByteString().toStringUtf8())
                            .setMsgbody(body.toByteString().toStringUtf8())
                            .build();

                    // PrintWriter out = new PrintWriter(new BufferedWriter(
                    // new OutputStreamWriter(socket.getOutputStream())),
                    // true);
                    // out.println(m.toString());
                    // out.println(m.toByteString().toStringUtf8());

                    // 向服务器发送信息
                    msg.writeTo(socket.getOutputStream());
                    //byte[] b = msg.toByteArray();
                    //smsobj.sendMsg(b);

                    // System.out.println("====msg==="
                    // + m.toByteString().toStringUtf8());
                   
                    // byte[] backBytes = smsobj.recvMsg();
                    //
                    // 接受服务器的信息
                    InputStream input = socket.getInputStream();

                    // DataInputStream dataInput=new DataInputStream();
                    //byte[] by = smsobj.recvMsg(input);
                    byte[] by=recvMsg(input);
                    setText(CMsg.parseFrom(by));

                    // BufferedReader br = new BufferedReader(
                    // new InputStreamReader(socket.getInputStream()));
                    // String mstr = br.readLine();
                    // if (!str .equals("")) {
                    // text1.setText(str);
                    // } else {
                    // text1.setText("数据错误");
                    // }
                    // out.close();
                    // br.close();

                    input.close();
                    //smsobj.close();
                    socket.close();
                } catch (UnknownHostException e) {
                    e.printStackTrace();
                } catch (IOException e) {
                    e.printStackTrace();
                } catch (Exception e) {
                    System.out.println(e.toString());
                }
                // };
                // }.start();

            }
        });

    }
   
    /**
     * 接收server的信息
     *
     * @return
     * @throws SmsClientException
     * @author fisher
     */
    public byte[] recvMsg(InputStream inpustream) throws SmsObjException {
        try {
 
            byte len[] = new byte[1024];
            int count = inpustream.read(len); 
       
            byte[] temp = new byte[count];
            for (int i = 0; i < count; i++) {  
                    temp[i] = len[i];                             
            }
            return temp;
        } catch (Exception localException) {
            throw new SmsObjException("SmapObj.recvMsg() occur exception!"
                    + localException.toString());
        }
    }

    /**
     * 得到返回值添加到文本里面
     *
     * @param g
     * @throws InvalidProtocolBufferException
     */
    public void setText(CMsg g) throws InvalidProtocolBufferException {
        CMsgHead h = CMsgHead.parseFrom(g.getMsghead().getBytes());
        StringBuffer sb = new StringBuffer();
        if (h.hasMsglen())
            sb.append("==len===" + h.getMsglen() + "n");
        if (h.hasMsgres())
            sb.append("==res===" + h.getMsgres() + "n");
        if (h.hasMsgseq())
            sb.append("==seq===" + h.getMsgseq() + "n");
        if (h.hasMsgtype())
            sb.append("==type===" + h.getMsgtype() + "n");
        if (h.hasTermid())
            sb.append("==Termid===" + h.getTermid() + "n");
        if (h.hasTermversion())
            sb.append("==Termversion===" + h.getTermversion() + "n");

        CMsgReg bo = CMsgReg.parseFrom(g.getMsgbody().getBytes());
        if (bo.hasArea())
            sb.append("==area==" + bo.getArea() + "n");
        if (bo.hasRegion())
            sb.append("==Region==" + bo.getRegion() + "n");
        if (bo.hasShop())
            sb.append("==shop==" + bo.getShop() + "n");
        if (bo.hasRet())
            sb.append("==Ret==" + bo.getRet() + "n");
        if (bo.hasTermid())
            sb.append("==Termid==" + bo.getTermid() + "n");

        text1.setText(sb.toString());
    }


服务端代码:

 代码如下 复制代码

package server;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

import msginfo.Msg.CMsg;
import msginfo.Msg.CMsgHead;
import msginfo.Msg.CMsgReg;

public class AndroidServer implements Runnable {

    public void run() {
        try {
            System.out.println("beign:");
            ServerSocket serverSocket = new ServerSocket(12345);
            while (true) {
                System.out.println("等待接收用户连接:");
                // 接受客户端请求
                Socket client = serverSocket.accept();

                DataOutputStream dataOutputStream;
                DataInputStream dataInputStream;

                try {
                    // 接受客户端信息
                    // BufferedReader in = new BufferedReader(
                    // new InputStreamReader(client.getInputStream()));
                    // String str = in.readLine();
                    // System.out.println("read length:  " + str.length());
                    // System.out.println("read:  " + str);

                    // InputStream inputstream = client.getInputStream();
                    // byte[] buffer = new byte[1024 * 4];
                    // int temp = 0;
                    // while ((temp = inputstream.read(buffer)) != -1) {
                    // str = new String(buffer, 0, temp);
                    // System.out.println("===str===" + str);

                    // File file = new File("userloglogin.log");
                    // appendLog(file, str);

                    InputStream inputstream = client.getInputStream();

                    dataOutputStream = new DataOutputStream(
                            client.getOutputStream());
                    //dataInputStream = new DataInputStream(inputstream);

                    // byte[] d = new BufferedReader(new InputStreamReader(
                    // dataInputStream)).readLine().getBytes();
                    // byte[] bufHeader = new byte[4];
                    // dataInputStream.readFully(bufHeader);
                    // int len = BytesUtil.Bytes4ToInt(bufHeader);
                    // System.out.println(d.length);
                    // System.out.println(dataInputStream.readLine().toString());
                    byte len[] = new byte[1024];
                    int count = inputstream.read(len); 
               
                    byte[] temp = new byte[count];
                   
                    for (int i = 0; i < count; i++) {  
                       
                            temp[i] = len[i];                             
                    }

                    // 协议正文
//                     byte[] sendByte = new byte[30];
//                   
//                     dataInputStream.readFully(sendByte);
//                     for (byte b : sendByte) {
//                     System.out.println(""+b);
//                     }
                    CMsg msg = CMsg.parseFrom(temp);
                    //
                    //
                    CMsgHead head = CMsgHead.parseFrom(msg.getMsghead()
                            .getBytes());
                    System.out.println("==len===" + head.getMsglen());
                    System.out.println("==res===" + head.getMsgres());
                    System.out.println("==seq===" + head.getMsgseq());
                    System.out.println("==type===" + head.getMsgtype());
                    System.out.println("==Termid===" + head.getTermid());
                    System.out.println("==Termversion==="
                            + head.getTermversion());

                    CMsgReg body = CMsgReg.parseFrom(msg.getMsgbody()
                            .getBytes());
                    System.out.println("==area==" + body.getArea());
                    System.out.println("==Region==" + body.getRegion());
                    System.out.println("==shop==" + body.getShop());

                    // PrintWriter out = new PrintWriter(new BufferedWriter(
                    // new OutputStreamWriter(client.getOutputStream())),
                    // true);
                    // out.println("return    " +msg.toString());

                    // in.close();
                    // out.close();

                    sendProtoBufBack(dataOutputStream);

                    inputstream.close();
                    //dataInputStream.close();
                } catch (Exception ex) {
                    System.out.println(ex.getMessage());
                    ex.printStackTrace();
                } finally {
                    client.close();
                    System.out.println("close");
                }
            }
        } catch (IOException e) {
            System.out.println(e.getMessage());
        }
    }

    public static void main(String[] args) {
        Thread desktopServerThread = new Thread(new AndroidServer());
        desktopServerThread.start();
    }

    private byte[] getProtoBufBack() {

        // head
        CMsgHead head = CMsgHead.newBuilder().setMsglen(5)
                .setMsgtype(1).setMsgseq(3).setTermversion(41)
                .setMsgres(5).setTermid("11111111").build();

        // body
        CMsgReg body = CMsgReg.newBuilder().setArea(22)
                .setRegion(33).setShop(44).build();

        // Msg
        CMsg msg = CMsg.newBuilder()
                .setMsghead(head.toByteString().toStringUtf8())
                .setMsgbody(body.toByteString().toStringUtf8())
                .build();

        return msg.toByteArray();
    }

    private void sendProtoBufBack(DataOutputStream dataOutputStream) {

        byte[] backBytes = getProtoBufBack();
        // 协议头部
    //    Integer len2 = backBytes.length;
        // 前四个字节,标示协议正文长度
    //    byte[] cmdHead2 = BytesUtil.IntToBytes4(len2);

        try {
            //dataOutputStream.write(cmdHead2, 0, cmdHead2.length);
            dataOutputStream.write(backBytes, 0, backBytes.length);
            dataOutputStream.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}



最后得到的效果:

客户端:

Android基于Protobuf的Socket通讯开发教程

服务端:

Android基于Protobuf的Socket通讯开发教程

protobuf .net版的实现代码如下:

 代码如下 复制代码

using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using Google.ProtocolBuffers;
using msginfo;
using System.Text;
using System.Collections;
using System.Collections.Generic;

namespace protobuf_csharp_sport
{
    class Program
    {
        private static ManualResetEvent allDone = new ManualResetEvent(false);

        static void Main(string[] args)
        {
            beginProtocbuf();
        }

        private static void beginProtocbuf()
        {
            //启动服务端
            TcpListener server = new TcpListener(IPAddress.Parse("127.0.0.1"), 12345);
            server.Start();
            server.BeginAcceptTcpClient(clientConnected, server);
            Console.WriteLine("SERVER : 等待数据 ---");

            //启动客户端
            ThreadPool.QueueUserWorkItem(runClient);
            allDone.WaitOne();

            Console.WriteLine("SERVER : 退出 ---");
            // server.Stop();
        }

        //服务端处理
        private static void clientConnected(IAsyncResult result)
        {
            try
            {
                TcpListener server = (TcpListener)result.AsyncState;
                using (TcpClient client = server.EndAcceptTcpClient(result))
                {
                    using (NetworkStream stream = client.GetStream())
                    {
                        //获取
                        Console.WriteLine("SERVER : 客户端已连接,数据读取中 --- ");
                        byte[] myRequestBuffer = new byte[1024];

                        int myRequestLength = 0;
                        do
                        {
                            myRequestLength = stream.Read(myRequestBuffer, 0, myRequestBuffer.Length);
                        }
                        while (stream.DataAvailable);
                        
                        CMsg msg = CMsg.ParseFrom(myRequestBuffer.RemoveEmptyByte(myRequestLength));

                        CMsgHead head = CMsgHead.ParseFrom(Encoding.ASCII.GetBytes(msg.Msghead));
                        CMsgReg body = CMsgReg.ParseFrom(Encoding.ASCII.GetBytes(msg.Msgbody));

                        IDictionary<Google.ProtocolBuffers.Descriptors.FieldDescriptor, object> d = head.AllFields;
                        foreach (var item in d)
                        {
                            Console.WriteLine(item.Value.ToString());
                        }

                        d = body.AllFields;
                        Console.WriteLine("===========================================");
                        foreach (var item in d)
                        {
                            Console.WriteLine(item.Value.ToString());
                        }
                     
                        Console.WriteLine("SERVER : 响应成功 ---");

                        Console.WriteLine("SERVER: 关闭连接 ---");
                        stream.Close();
                    }
                    client.Close();
                }
            }
            finally
            {
                allDone.Set();
            }
        }

        //客户端请求
        private static void runClient(object state)
        {
            try
            {
                CMsgHead head = CMsgHead.CreateBuilder()
                    .SetMsglen(5)
                    .SetMsgtype(1)
                    .SetMsgseq(3)
                    .SetTermversion(4)
                    .SetMsgres(5)
                    .SetTermid("11111111")
                    .Build();

                CMsgReg body = CMsgReg.CreateBuilder().
                    SetArea(22)
                   .SetRegion(33)
                   .SetShop(44)
                   .Build();

                CMsg msg = CMsg.CreateBuilder()
                    .SetMsghead(head.ToByteString().ToStringUtf8())
                    .SetMsgbody(body.ToByteString().ToStringUtf8())
                    .Build();


                Console.WriteLine("CLIENT : 对象构造完毕 ...");

                using (TcpClient client = new TcpClient())
                {
                    // client.Connect(new IPEndPoint(IPAddress.Parse("192.168.1.116"), 12345));
                    client.Connect(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 12345));
                    Console.WriteLine("CLIENT : socket 连接成功 ...");

                    using (NetworkStream stream = client.GetStream())
                    {
                        //发送
                        Console.WriteLine("CLIENT : 发送数据 ...");
                     
                        msg.WriteTo(stream);

                        //关闭
                        stream.Close();
                    }
                    client.Close();
                    Console.WriteLine("CLIENT : 关闭 ...");
                }
            }
            catch (Exception error)
            {
                Console.WriteLine("CLIENT ERROR : {0}", error.ToString());
            }
        }

    }//end class



    public static class ExtensionClass {
        public static byte[] RemoveEmptyByte(this byte[] by,int length)
        {
            byte[] returnByte = new byte[length];

            for (int i = 0; i < length; i++)
            {
                returnByte[i] = by[i];
            }
            return returnByte;

        }
    }



运行的效果:

Android基于Protobuf的Socket通讯开发教程


这样就OK了,之后就可以把java 服务端的IP或端口改成C# IP和服务端的商品一样,或者反过来也是可以的。c++版本经过测试也是可以的。简直是一个爽字。

本文Protobuf实现Android Socket通讯开发教程就为您介绍到这里了!

 

本教程主要讲讲Android五大布局,即LinearLayout(线性布局)、FrameLayout(单帧布局)、RelativeLayout(相对布局)、AbsoluteLayout(绝对布局)和TableLayout(表格布局)。

Android的界面是有布局和组件协同完成,布局好比是建筑里的框架,而组件则相当于建筑里的砖瓦。组件按照布局的要求依次排列,就组成了用户所看见的界面。

LinearLayout:

LinearLayout按照垂直或者水平的顺序依次排列子元素,每一个子元素都位于前一个元素之后。如果是垂直排列,那么将是一个N行单列的结构,每一行只会有一个元素,而不论这个元素的宽度为多少;如果是水平排列,那么将是一个单行N列的结构。如果搭建两行两列的结构,通常的方式是先垂直排列两个元素,每一个元素里再包含一个LinearLayout进行水平排列。

LinearLayout中的子元素属性android:layout_weight生效,它用于描述该子元素在剩余空间中占有的大小比例。加入一行只有一个文本框,那么它的默认值就为0,如果一行中有两个等长的文本框,那么他们的android:layout_weight值可以是同为1。如果一行中有两个不等长的文本框,那么他们的android:layout_weight值分别为1和2,那么第一个文本框将占据剩余空间的三分之二,第二个文本框将占据剩余空间中的三分之一。android:layout_weight遵循数值越小,重要度越高的原则。显示效果如下:

Android五大布局教程LinearLayout、FrameLayout、AbsoulteLayout、RelativeLayout和TableLayout

 代码如下 复制代码
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent">
<TextView  android:layout_width="fill_parent" android:layout_height="wrap_content" android:background="#ff000000" android:text="@string/hello"/>
<LinearLayout android:orientation="horizontal" android:layout_width="fill_parent" android:layout_height="fill_parent">
<TextView  android:layout_width="fill_parent" android:layout_height="wrap_content" android:background="#ff654321" android:layout_weight="1" android:text="1"/>
<TextView  android:layout_width="fill_parent" android:layout_height="wrap_content" android:background="#fffedcba" android:layout_weight="2"  android:text="2"/>
</LinearLayout>
</LinearLayout>

FrameLayout:

FrameLayout是五大布局中最简单的一个布局,在这个布局中,整个界面被当成一块空白备用区域,所有的子元素都不能被指定放置的位置,它们统统放于这块区域的左上角,并且后面的子元素直接覆盖在前面的子元素之上,将前面的子元素部分和全部遮挡。显示效果如下,第一个TextView被第二个TextView完全遮挡,第三个TextView遮挡了第二个TextView的部分位置。

 

Android五大布局教程LinearLayout、FrameLayout、AbsoulteLayout、RelativeLayout和TableLayout

 

 代码如下 复制代码
<?xml version="1.0" encoding="utf-8"?>
<FrameLayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent">
<TextView android:layout_width="fill_parent" android:layout_height="fill_parent" android:background="#ff000000" android:gravity="center" android:text="1"/>
<TextView android:layout_width="fill_parent" android:layout_height="fill_parent" android:background="#ff654321" android:gravity="center" android:text="2"/>
<TextView android:layout_width="50dp" android:layout_height="50dp" android:background="#fffedcba" android:gravity="center" android:text="3"/>
</FrameLayout>

AbsoluteLayout:

AbsoluteLayout是绝对位置布局。在此布局中的子元素的android:layout_x和android:layout_y属性将生效,用于描述该子元素的坐标位置。屏幕左上角为坐标原点(0,0),第一个0代表横坐标,向右移动此值增大,第二个0代表纵坐标,向下移动,此值增大。在此布局中的子元素可以相互重叠。在实际开发中,通常不采用此布局格式,因为它的界面代码过于刚性,以至于有可能不能很好的适配各种终端。显示效果如下:

Android五大布局教程LinearLayout、FrameLayout、AbsoulteLayout、RelativeLayout和TableLayout

 

 

 代码如下 复制代码
<?xml version="1.0" encoding="utf-8"?>
<AbsoluteLayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent">
<TextView android:layout_width="50dp" android:layout_height="50dp" android:background="#ffffffff" android:gravity="center" android:layout_x="50dp" android:layout_y="50dp" android:text="1"/>
<TextView android:layout_width="50dp" android:layout_height="50dp" android:background="#ff654321" android:gravity="center" android:layout_x="25dp" android:layout_y="25dp" android:text="2"/>
<TextView  android:layout_width="50dp" android:layout_height="50dp" android:background="#fffedcba" android:gravity="center" android:layout_x="125dp" android:layout_y="125dp" android:text="3"/>
</AbsoluteLayout>

RelativeLayout:

RelativeLayout按照各子元素之间的位置关系完成布局。在此布局中的子元素里与位置相关的属性将生效。例如android:layout_below, android:layout_above等。子元素就通过这些属性和各自的ID配合指定位置关系。注意在指定位置关系时,引用的ID必须在引用之前,先被定义,否则将出现异常。

RelativeLayout里常用的位置属性如下:

android:layout_toLeftOf —— 该组件位于引用组件的左方
android:layout_toRightOf —— 该组件位于引用组件的右方
android:layout_above —— 该组件位于引用组件的上方
android:layout_below —— 该组件位于引用组件的下方
android:layout_alignParentLeft —— 该组件是否对齐父组件的左端
android:layout_alignParentRight —— 该组件是否齐其父组件的右端
android:layout_alignParentTop —— 该组件是否对齐父组件的顶部
android:layout_alignParentBottom —— 该组件是否对齐父组件的底部
android:layout_centerInParent —— 该组件是否相对于父组件居中
android:layout_centerHorizontal —— 该组件是否横向居中
android:layout_centerVertical —— 该组件是否垂直居中

RelativeLayout是Android五大布局结构中最灵活的一种布局结构,比较适合一些复杂界面的布局。下面示例就展示这么一个情况,第一个文本框与父组件的底部对齐,第二个文本框位于第一个文本框的上方,并且第三个文本框位于第二个文本框的左方。

Android五大布局教程LinearLayout、FrameLayout、AbsoulteLayout、RelativeLayout和TableLayout

 代码如下 复制代码
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent">
<TextView android:id="@+id/text_01" android:layout_width="50dp" android:layout_height="50dp" android:background="#ffffffff" android:gravity="center" android:layout_alignParentBottom="true" android:text="1"/>
<TextView android:id="@+id/text_02" android:layout_width="50dp" android:layout_height="50dp" android:background="#ff654321" android:gravity="center" android:layout_above="@id/text_01" android:layout_centerHorizontal="true" android:text="2"/>
<TextView android:id="@+id/text_03" android:layout_width="50dp" android:layout_height="50dp" android:background="#fffedcba" android:gravity="center" android:layout_toLeftOf="@id/text_02" android:layout_above="@id/text_01" android:text="3"/>
</RelativeLayout>


TableLayout:


TableLayout顾名思义,此布局为表格布局,适用于N行N列的布局格式。一个TableLayout由许多TableRow组成,一个TableRow就代表TableLayout中的一行。

TableRow是LinearLayout的子类,它的android:orientation属性值恒为horizontal,并且它的android:layout_width和android:layout_height属性值恒为MATCH_PARENT和WRAP_CONTENT。所以它的子元素都是横向排列,并且宽高一致的。这样的设计使得每个TableRow里的子元素都相当于表格中的单元格一样。在TableRow中,单元格可以为空,但是不能跨列。

下面示例演示了一个TableLayout的布局结构,其中第二行只有两个单元格,而其余行都是三个单元格。

 

Android五大布局教程LinearLayout、FrameLayout、AbsoulteLayout、RelativeLayout和TableLayout

 代码如下 复制代码
<?xml version="1.0" encoding="utf-8"?>
<TableLayout xmlns:android="http://schemas.android.com/apk/res/android" android:orientation="vertical" android:layout_width="fill_parent" android:layout_height="fill_parent">
<TableRow android:layout_width="fill_parent" android:layout_height="wrap_content">
<TextView  android:background="#ffffffff" android:gravity="center" android:padding="10dp" android:text="1"/>
<TextView android:background="#ff654321" android:gravity="center" android:padding="10dp" android:text="2"/>
<TextView  android:background="#fffedcba" android:gravity="center" android:padding="10dp" android:text="3"/>
</TableRow>
<TableRow android:layout_width="fill_parent" android:layout_height="wrap_content">
<TextView  android:background="#ff654321" android:gravity="center" android:padding="10dp" android:text="2"/>
<TextView android:background="#fffedcba" android:gravity="center" android:padding="10dp" android:text="3"/>       
</TableRow>
<TableRow android:layout_width="fill_parent" android:layout_height="wrap_content">
<TextView android:background="#fffedcba" android:gravity="center" android:padding="10dp" android:text="3"/>
<TextView  android:background="#ff654321" android:gravity="center" android:padding="10dp" android:text="2"/>
<TextView  android:background="#ffffffff" android:gravity="center" android:padding="10dp" android:text="1"/>       
</TableRow>
</TableLayout>

 

标签:[!--infotagslink--]

您可能感兴趣的文章: