android中所有活动的单socket.IO连接

Posted

技术标签:

【中文标题】android中所有活动的单socket.IO连接【英文标题】:Single socket.IO connection for all activities in android 【发布时间】:2014-08-29 05:35:40 【问题描述】:

我已经为here 的 SocketIOClient 引用创建了 Singleton 类。服务器已连接。我可以将请求从活动发送到 SocketIOClient。但是如何从 Activity 中的 Singleton 类获得响应?

这里是我的活动:

import java.net.MalformedURLException;
import org.json.JSONException;
import org.json.JSONObject;
import android.app.Activity;
import android.os.Bundle;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.Toast;


public class MainActivity extends Activity 
    EditText uname, passwd;
    Button login;
    JSONObject json;
    SocketIOClient socket;

@Override
protected void onCreate(Bundle savedInstanceState) 
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    socket = new SocketIOClient();
    try 
        SocketIOClient.initInstance();
     catch (MalformedURLException e1) 
        // TODO Auto-generated catch block
        e1.printStackTrace();
    

    json = new JSONObject();
    uname = (EditText) findViewById(R.id.unameED);
    passwd = (EditText) findViewById(R.id.passwdED);
    login = (Button) findViewById(R.id.loginButton);
    login.setOnClickListener(new OnClickListener() 

        @Override
        public void onClick(View v) 
            // TODO Auto-generated method stub

            try 
                json.put("username", uname.getText().toString().trim());
                json.put("password", passwd.getText().toString().trim());
              //request send to server    
                SocketIOClient.emit("login_request", json);

             catch (Exception e) 
                // TODO Auto-generated catch block
                e.printStackTrace();
            

        
    );



 

我的单例类也有 on() 方法:

        @Override
        public void on(String event, IOAcknowledge ack, Object... args) 
            JSONArray jarr_args = new JSONArray();
            JSONObject jobj_in = new JSONObject();
            if (event.equals("registration_status")) 
                jarr_args.put(args[0]);
                try 
                    jobj_in = jarr_args.getJSONObject(0);
                    Log.d("Result", jobj_in.getString("result"));
                    if (jobj_in.getString("result").equals("success")) 

                     else 
                        Log.d("check:", "username and password");

                    
                 catch (JSONException e) 
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                
            
        

这里的 Singleton 类可以得到服务器的响应。但我想知道,如何在我的活动中获得响应?

【问题讨论】:

在您的活动中创建一个回调方法,因此您需要使用单例类注册一个列表器,一旦类获取数据,它将调用您注册的方法。 感谢您的回复。我是java的新手。你能举一个例子来实现吗? 【参考方案1】:

像这样创建一个抽象类

public abstract class ResponseHandler 

    private Context context;

    public abstract void execute (JSONObject jsonObject) throws JSONException;

    public ResponseHandler (Context ctx)
    
        this.context = ctx;
    

    public void handleObject(JSONObject jsonObject) throws Exception
    
        execute(jsonObject);

    

在您的活动中 在调用套接字类时,也将 ResponseHadler 作为参数传递 示例:

SocketIOClient.initInstance(your parameters, new ResponseHandler(this)

    //ResponseHandler have an abstract method called execute(). So you are overriding it here
    @Override
    public void execute(JSONObject jsonObject) throws JSONException
    
        // Here you will get your JSONObject passed from socket class
    

在你的套接字类中

public class YourSocketClass

private ResponseHandler handler;

public static void initInstance(your parameter, ResponseHandler responseHandler)

    this.handler = responseHandler;

    // Do your operations here      


@Override
public void on(String event, IOAcknowledge ack, Object... args) 

    JSONArray jarr_args = new JSONArray();
    JSONObject jobj_in = new JSONObject();
    if (event.equals("registration_status")) 
    
        jarr_args.put(args[0]);
        try 
        
            jobj_in = jarr_args.getJSONObject(0);
            Log.d("Result", jobj_in.getString("result"));
            if (jobj_in.getString("result").equals("success")) 
            
                //If you want to pass your jsonobject from here to activity
                //Do something like this
                handler.handleObject(jobj_in);
             
            else 
            
                Log.d("check:", "username and password");
            
         
        catch (JSONException e) 
        
            e.printStackTrace();
        
    


【讨论】:

以上是关于android中所有活动的单socket.IO连接的主要内容,如果未能解决你的问题,请参考以下文章

断开连接时销毁socket.io连接

非活动客户端连接的socket.io服务器端超时?

( Socket.io ) 一个socket连接多个房间

socket.io 通过 XHR 轮询强制断开连接

Socket.io - 分享“好友活动”设计模式

使用 HTTPS 协议的 android 连接中的 Socket.io 客户端失败?