Android:IntentService的使用

一、IntentService简介 

IntentService是Service的子类,比普通的Service增加了额外的功能。先看Service本身存在两个问题  

  • Service不会专门启动一条单独的进程,Service与它所在应用位于同一个进程中  

  • Service也不是专门一条新线程,因此不应该在Service中直接处理耗时的任务  

  

二、IntentService特征 

  • 会创建独立的worker线程来处理所有的Intent请求  

  • 会创建独立的worker线程来处理onHandleIntent()方法实现的代码,无需处理多线程问题  

  • 所有请求处理完成后,IntentService会自动停止,无需调用stopSelf()方法停止Service  

  • 为Service的onBind()提供默认实现,返回null  

  • 为Service的onStartCommand提供默认实现,将请求Intent添加到队列中 

 

三、使用步骤(详情参考Service项目) 

  1. 继承IntentService类,并重写onHandleIntent()方法即可 

MainActivity.java文件 

public class MainActivity extends Activity { 
 
    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
        super.onCreate(savedInstanceState); 
        setContentView(R.layout.activity_main); 
    } 
 
    public void startService(View source) { 
        // 创建所需要启动的Service的Intent 
        Intent intent = new Intent(this, MyService.class); 
        startService(intent); 
    } 
 
    public void startIntentService(View source) { 
        // 创建需要启动的IntentService的Intent 
        Intent intent = new Intent(this, MyIntentService.class); 
        startService(intent); 
    } 
} 
 

MyIntentService.java文件 

public class MyIntentService extends IntentService { 
 
    public MyIntentService() { 
        super("MyIntentService"); 
    } 
 
    @Override 
    protected void onHandleIntent(Intent intent) { 
        // IntentService会使用单独的线程来执行该方法的代码 
        // 该方法内执行耗时任务,比如下载文件,此处只是让线程等待20秒 
        long endTime = System.currentTimeMillis() + 20 * 1000; 
        System.out.println("onStart"); 
        while (System.currentTimeMillis() < endTime) { 
            synchronized (this) { 
                try { 
                    wait(endTime - System.currentTimeMillis()); 
                } catch (InterruptedException e) { 
                    e.printStackTrace(); 
                } 
            } 
        } 
        System.out.println("----耗时任务执行完成---"); 
    } 
} 
 

MyService.java文件 

public class MyService extends Service { 
 
    @Override 
    public IBinder onBind(Intent arg0) { 
        return null; 
    } 
 
    @Override 
    public int onStartCommand(Intent intent, int flags, int startId) { 
        // 该方法内执行耗时任务可能导致ANR(Application Not Responding)异常 
        long endTime = System.currentTimeMillis() + 20 * 1000; 
        System.out.println("onStart"); 
        while (System.currentTimeMillis() < endTime) { 
            synchronized (this) { 
                try { 
                    wait(endTime - System.currentTimeMillis()); 
                } catch (InterruptedException e) { 
                    e.printStackTrace(); 
                } 
            } 
        } 
        System.out.println("----耗时任务执行完成---"); 
        return START_STICKY; 
    } 
} 
运行上述代码,启动MyIntentService的会使用单独的worker线程,因此不会阻塞前台的UI线程;而MyService会。

新技术,新未来!欢迎大家关注 “1024工场”微信服务号 ,时刻关注我们的最新的技术讯息! (甭客气!尽情的扫描或者长按!)

  • 12
    点赞
  • 12
    收藏
    觉得还不错? 一键收藏
  • 4
    评论
您好,如果您想在 IntentService使用 MQTT 协议进行消息传输,可以使用 Eclipse Paho Android 客户端库。以下是在 IntentService使用 Paho Android 客户端库实现 MQTT 的基本步骤: 1. 添加 Paho Android 客户端库到您的项目中。 2. 在 IntentService 的 `onCreate()` 方法中创建 MQTT 客户端并连接到 MQTT 代理服务器。您需要指定代理服务器的地址和端口号。可以使用 `MqttConnectOptions` 类设置连接选项,例如设置连接的用户名和密码、清除会话标志等。 3. 在 `onHandleIntent()` 方法中订阅主题、发布消息和处理接收到的消息。您需要实现 `MqttCallback` 接口,并在回调方法中处理接收到的消息。 以下是在 IntentService 中连接到 MQTT 代理服务器的示例代码: ```java public class MyIntentService extends IntentService { private static final String TAG = MyIntentService.class.getSimpleName(); private MqttAndroidClient client; public MyIntentService() { super(TAG); } @Override public void onCreate() { super.onCreate(); String brokerUrl = "tcp://mqtt.eclipse.org:1883"; String clientId = MqttClient.generateClientId(); client = new MqttAndroidClient(this, brokerUrl, clientId); MqttConnectOptions options = new MqttConnectOptions(); options.setUserName("username"); options.setPassword("password".toCharArray()); options.setCleanSession(true); try { IMqttToken token = client.connect(options); token.waitForCompletion(); } catch (MqttException e) { Log.e(TAG, "Failed to connect to MQTT broker", e); } } @Override protected void onHandleIntent(Intent intent) { // 在这里订阅主题、发布消息和处理接收到的消息 // ... // 订阅主题 String topic = "my/topic"; int qos = 1; try { IMqttToken token = client.subscribe(topic, qos); token.waitForCompletion(); } catch (MqttException e) { Log.e(TAG, "Failed to subscribe to topic: " + topic, e); } // 发布消息 String message = "Hello, MQTT!"; try { client.publish(topic, message.getBytes(), qos, false); } catch (MqttException e) { Log.e(TAG, "Failed to publish message: " + message, e); } } @Override public void onDestroy() { super.onDestroy(); try { IMqttToken token = client.disconnect(); token.waitForCompletion(); } catch (MqttException e) { Log.e(TAG, "Failed to disconnect from MQTT broker", e); } } } ``` 您还需要实现 `MqttCallback` 接口并在回调方法中处理接收到的消息。例如: ```java client.setCallback(new MqttCallback() { @Override public void connectionLost(Throwable cause) { // 处理连接丢失事件 } @Override public void messageArrived(String topic, MqttMessage message) throws Exception { // 处理接收到的消息 String payload = new String(message.getPayload()); Log.d(TAG, "Received message: " + payload); } @Override public void deliveryComplete(IMqttDeliveryToken token) { // 处理消息发送完成事件 } }); ``` 在 `onDestroy()` 方法中断开 MQTT 客户端与代理服务器的连接。 希望这些信息能对您有所帮助。

“相关推荐”对你有帮助么?

  • 非常没帮助
  • 没帮助
  • 一般
  • 有帮助
  • 非常有帮助
提交
评论 4
添加红包

请填写红包祝福语或标题

红包个数最小为10个

红包金额最低5元

当前余额3.43前往充值 >
需支付:10.00
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明:

1.余额是钱包充值的虚拟货币,按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载,可以购买VIP、付费专栏及课程。

余额充值