5

基本上我有一个运行整个项目的主类。该代码运行良好,尽管一旦应用程序不聚焦,它就会变为非活动状态。我想知道我将如何使它成为一项服务。一个会在启动时启动的。

该应用程序将成为通知的单向消息系统。IE

桌面客户端 -> Openfire 服务器 -> Android XMPP 服务 -> 存储 (DB) -> 用于显示的 Android GUI

正如我所说,代码正在运行(连接、登录、接收),但不是服务。

我可以使用 BEEM 源,但它过于特色和交错。我追求的是轻量级服务。

编码:

public class MainActivity extends Activity {

  public static final String HOST = "fire.example.com";
  public static final int PORT = 5222;
  public static final String SERVICE = "example.com";
  public static final String USERNAME = "metest@fire.example.com";
  public static final String PASSWORD = "mepass";

  private XMPPConnection connection;
  private ArrayList<String> messages = new ArrayList<String>();
  private Handler mHandler = new Handler();
  private ListView listview;
  /** Called when the activity is first created. */
  @Override
  public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

    listview = (ListView) this.findViewById(R.id.listMessages);
    setListAdapter();

    connect();
  }

  /**
   * Called by Settings dialog when a connection is establised with 
   * the XMPP server
   */
  public void setConnection(XMPPConnection connection) {
    this.connection = connection;
    if (connection != null) {
      // Add a packet listener to get messages sent to us
      PacketFilter filter = new MessageTypeFilter(Message.Type.chat);
      connection.addPacketListener(new PacketListener() {
        @Override
        public void processPacket(Packet packet) {
          Message message = (Message) packet;
          if (message.getBody() != null) {
            String fromName = StringUtils.parseBareAddress(message.getFrom());
            Log.i("XMPPChatActivity ", " Text Recieved " + message.getBody() + " from " +  fromName);

            messages.add(message.getBody());


            mHandler.post(new Runnable() {
              public void run() {
                setListAdapter();
              }
            });
          }
        }


      }, filter);
    }
  }
  @TargetApi(Build.VERSION_CODES.HONEYCOMB)
@SuppressLint("NewApi")


  private void setListAdapter() {
    ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, R.layout.listitem, messages);
    listview.setAdapter(adapter);
  }

  @Override
  protected void onDestroy() {
    super.onDestroy();
    try {
      connection.disconnect();
    } catch (Exception e) {

    }
  }

  public void connect() {

    final ProgressDialog dialog = ProgressDialog.show(this, "Connecting...", "Please wait...", false);
    Thread t = new Thread(new Runnable() {
      @Override
      public void run() {
        // Create a connection
       ConnectionConfiguration connConfig = new ConnectionConfiguration(HOST, PORT, SERVICE);
       XMPPConnection connection = new XMPPConnection(connConfig);
         try {
           connection.connect();
           Log.i("XMPPChatActivity",  "[SettingsDialog] Connected to "+connection.getHost());
         } catch (XMPPException ex) {
             Log.e("XMPPChatActivity",  "[SettingsDialog] Failed to connect to "+ connection.getHost());
             Log.e("XMPPChatActivity", ex.toString());
             setConnection(null);
         }
          try {
            connection.login(USERNAME, PASSWORD);
            Log.i("XMPPChatActivity",  "Logged in as" + connection.getUser());

            // Set the status to available
            Presence presence = new Presence(Presence.Type.available);
            connection.sendPacket(presence);
            setConnection(connection);

            Roster roster = connection.getRoster();
            Collection<RosterEntry> entries = roster.getEntries();
            for (RosterEntry entry : entries) {

              Log.d("XMPPChatActivity",  "--------------------------------------");
              Log.d("XMPPChatActivity", "RosterEntry " + entry);
              Log.d("XMPPChatActivity", "User: " + entry.getUser());
              Log.d("XMPPChatActivity", "Name: " + entry.getName());
              Log.d("XMPPChatActivity", "Status: " + entry.getStatus());
              Log.d("XMPPChatActivity", "Type: " + entry.getType());
              Presence entryPresence = roster.getPresence(entry.getUser());

              Log.d("XMPPChatActivity", "Presence Status: "+ entryPresence.getStatus());
              Log.d("XMPPChatActivity", "Presence Type: " + entryPresence.getType());

              Presence.Type type = entryPresence.getType();
              if (type == Presence.Type.available)
                Log.d("XMPPChatActivity", "Presence AVIALABLE");
                Log.d("XMPPChatActivity", "Presence : " + entryPresence);
              }
              } catch (XMPPException ex) {
                Log.e("XMPPChatActivity", "Failed to log in as "+  USERNAME);
                Log.e("XMPPChatActivity", ex.toString());
                setConnection(null);
              }
              dialog.dismiss();
           }
      });
    t.start();
    dialog.show();
  }
}

所以基本上,我如何使它成为一项服务

4

3 回答 3

3

我想给定链接上的这个例子会给你一个让它成为服务的想法。http://android.codeandmagic.org/small-test-of-asmack-xmpp-client-library/

于 2014-05-17T18:02:57.297 回答
1

您需要使用 Android服务框架。

您可以查看GTalk SMS源,因为它们使用服务并且是开源的。(主要服务是他们用来处理连接等的服务)虽然它也很复杂。

我强烈建议您查看在 Android 中使用服务的基础知识。

请记住,服务不会创建新线程,一切仍然在 UI 线程上完成,因此如果您想在后台执行长时间运行的任务,那么您还需要实现 asynctask 或 executor 服务。

于 2013-08-06T23:53:15.830 回答
0

老问题,但无论如何我都会回答。
您需要创建一个服务,启动它并将您的 aSmack 连接代码放在服务中,而不是任何活动中。即使应用程序不在前台,该服务也会保留连接。我在我的一个客户的应用程序中使用这种方法,效果很好。

此外,请确保在服务中使用 Handler 或 AsyncTask 在另一个非 UI 线程中创建套接字连接。Android 无论如何都不允许您在 UI 线程中创建连接。

于 2015-01-25T11:12:29.870 回答