Android基于XMPP Smack及Openfire学习笔记（1）

2022-08-07 19:44:51

之前开发的项目中实用到IM聊天功能。可是这块功能公司有专门的IM团队来开发，由他们开发好后。直接接入到我们APP中。我參与写IM相关功能非常地少，所以也一直想学习相关知识。

眼下Android主要用的是XMPP协议及OPenfireserver来实现IM功能，我也从这块入手学习。也感谢全部分享资料让我有机会学习的同行们。

如今正式開始啦。

第一步：搭建Openfireserver：

Openfire工具下载地址：http://www.igniterealtime.org/downloads/index.jsp

下载到本地点击安装。一步步进行就可以。网上的安装指导方法也非常多。我就參考了

站点：http://www.cnblogs.com/hoojo/archive/2012/05/17/2506769.html。

第二步：下载及安装 Spark：

下载地址：http://www.igniterealtime.org/downloads/index.jsp，我下载的也是最新

Windows版本号Spark 2.7.5(spark_2_7_5.exe)。直接安装就可以。这是一个相似QQ的聊天工具，

当你安装好Openfire后。就有一个帐号如admin，能够用这个帐号在Spark上登录。

第三步：下载asmack.jar包，主要是用于我们项目开发的jar包。网上搜索下，下载地址非常多。

完毕上面三步，基本上就能够開始我们的开发工作了。

首先新建 Android项目，导入刚刚下载好的smack.jar包。今天上午主要学习的是通过Android端连接server及注冊用户。

//主界面，主要是4个button：连接。注冊。登录，改动password

public class MainActivity extends ActionBarActivity implements OnClickListener {

    private Button connect_server;

    private Button register;

    private Button login;

    private Button update_pwd;

    private Handler mHandler = new Handler() {

        public void handleMessage(android.os.Message msg) {

            if (msg.what == 1) {

                Toast.makeText(MainActivity.this, "连接server成功。", Toast.LENGTH_SHORT).show();

            }

            else {

                Toast.makeText(MainActivity.this, "连接server失败！

", Toast.LENGTH_SHORT).show();

            }

        };

    };

    @Override

    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.activity_main);

        initViewsAndEvents();

    }

    private void initViewsAndEvents() {

        this.connect_server = (Button) findViewById(R.id.connect_server);

        this.register = (Button) findViewById(R.id.register);

        this.login = (Button) findViewById(R.id.login);

        this.update_pwd = (Button) findViewById(R.id.update_pwd);

        this.connect_server.setOnClickListener(this);

        this.register.setOnClickListener(this);

        this.login.setOnClickListener(this);

        this.update_pwd.setOnClickListener(this);

    }

    @Override

    public void onClick(View v) {

        switch (v.getId()) {

            case R.id.connect_server:

                new Thread(new Runnable() {

                    @Override

                    public void run() {

                        boolean flag = isConnectServer();

                        Message msg = new Message();

                        if (flag) {

                            msg.what = 1;

                        }

                        mHandler.sendMessage(msg);

                    }

                }).start();

                break;

            case R.id.register:

                startActivity(new Intent(MainActivity.this, RegisterActivity.class));

                break;

            case R.id.login:

                break;

            case R.id.update_pwd:

                break;

        }

    }

    private boolean isConnectServer() {

        boolean isConnect = false;

        // 第一步：初始化ConnectionConfiguration。參数是serverip,port号及server名称

        ConnectionConfiguration config = new ConnectionConfiguration("主机ip地址", 5222, "server名称");

        // 设置是否启用安全验证

        config.setSelfSignedCertificateEnabled(false);

        // 设置启用调试

        config.setDebuggerEnabled(true);

        // 同意自己主动连接

        config.setReconnectionAllowed(true);

        config.setSendPresence(true);

        // 设置安全模式

        config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);

        // 第二步：初始连接对象XMPPConnection

        XMPPConnection conn = new XMPPConnection(config);

        // 第三步：建立连接

        try {

            conn.connect();

            // 连接成功返回true;

            isConnect = true;

        }

        catch (XMPPException e) {

            e.printStackTrace();

        }

        return isConnect;

    }

}

/**

 * 注冊或登录页面

 * @description：

 * @date 2016-2-20 上午10:36:27

 */

public class RegisterActivity extends ActionBarActivity implements OnClickListener {

    private Button register;

    private EditText edt_name;

    private EditText edt_pwd;

    private Handler mHandler = new Handler() {

        public void handleMessage(android.os.Message msg) {

            Toast.makeText(RegisterActivity.this, msg.obj.toString(), Toast.LENGTH_SHORT).show();

            finish();

        };

    };

    @Override

    protected void onCreate(Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.register);

        initViewsAndEvents();

    }

    private void initViewsAndEvents() {

        this.register = (Button) findViewById(R.id.register);

        this.register.setOnClickListener(this);

        this.edt_name = (EditText) findViewById(R.id.edt_name);

        this.edt_pwd = (EditText) findViewById(R.id.edt_pwd);

    }

    @Override

    public void onClick(View v) {

        if (v.getId() == R.id.register) {

            new Thread(new Runnable() {

                @Override

                public void run() {

                    String reslut = registerToServier(edt_name.getText().toString().trim(), edt_pwd.getText().toString().trim());

                    Message msg = new Message();

                    msg.obj = reslut;

                    mHandler.sendMessage(msg);

                }

            }).start();

        }

    }

    /**

     * 注冊到server

     * @description：

     * @date 2016-2-20 上午10:41:09

     */

    private String registerToServier(String name, String pwd) {

        // 初始化ConnectionConfiguration，參数是serverip,port号及server名称

        ConnectionConfiguration config = new ConnectionConfiguration("serverip地址", 5222, "server名称");

        // 设置是否启用安全验证

        config.setSelfSignedCertificateEnabled(false);

        // 设置启用调试

        config.setDebuggerEnabled(true);

        // 同意自己主动连接

        config.setReconnectionAllowed(true);

        config.setSendPresence(true);

        // 设置安全模式

        config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);

        // 初始连接对象XMPPConnection

        XMPPConnection connection = new XMPPConnection(config);

        try {

            connection.connect();

        }

        catch (XMPPException e) {

            e.printStackTrace();

        }

        -上面连接server代码代码我又又一次写了一次。事实上应该进行封装，连接上server后。把connection对象保存起来-

        if (connection == null) return "0";

        // 初始化注冊Registration对象

        Registration reg = new Registration();

        reg.setType(IQ.Type.SET);

        // 设置注冊到的server名称

        reg.setTo("hx1401016");

        // 设置username

        reg.setUsername(name);

        // 设置password

        reg.setPassword(pwd);

        // 这边addAttribute不能为空，否则出错。所以做个标志是android手机创建的吧！！

！！

！

        reg.addAttribute("android", "geolo_createUser_android");

        PacketFilter filter = new AndFilter(new PacketIDFilter(reg.getPacketID()), new PacketTypeFilter(IQ.class));

        PacketCollector collector = connection.createPacketCollector(filter);

        connection.sendPacket(reg);

        IQ result = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout());

        // Stop queuing results

        collector.cancel();// 停止请求results（是否成功的结果）

        if (result == null) {

            return "server没响应";

        }

        else if (result.getType() == IQ.Type.RESULT) {

            return "注冊成功";

        }

        else { // if (result.getType() == IQ.Type.ERROR)

            if (result.getError().toString().equalsIgnoreCase("conflict(409)")) {

                return "注冊失败" + result.getError().toString();

            }

            else {

                return "注冊失败" + result.getError().toString();

            }

        }

    }

}

//主界面布局

<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:orientation="vertical" >

    <Button

        android:id="@+id/connect_server"

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:layout_margin="10dp"

        android:text="与server连接" />

    <Button

        android:id="@+id/register"

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:layout_margin="10dp"

        android:text="注冊" />

    <Button

        android:id="@+id/login"

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:layout_margin="10dp"

        android:text="登录 " />

    <Button

        android:id="@+id/update_pwd"

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:layout_margin="10dp"

        android:text="改动password" />

</LinearLayout>

//注冊页面布局

<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:orientation="vertical" >

    <EditText

        android:id="@+id/edt_name"

        android:layout_width="match_parent"

        android:layout_height="40dp"

        android:hint="请输入username"

        android:layout_margin="10dp"/>

    <EditText

        android:id="@+id/edt_pwd"

        android:layout_width="match_parent"

        android:layout_height="40dp"

        android:hint="请输入password"

        android:layout_margin="10dp" />

    <Button

        android:id="@+id/register"

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:layout_margin="10dp"

        android:text="注冊" />

</LinearLayout>

Openfire配置成功后，后台图片展示：

Android基于XMPP Smack及Openfire学习笔记（1）

代码中注冊成功的用户信息：

接下来来继续学习登录，改动password等。

码农公寓

相关文章