Android AWS S3 SDK TransferUtility 在服务中不起作用

Question

我正在尝试在已启动的服务中使用适用于 S3 的 AWS Android 开发工具包。我对 SDK 和服务都有点陌生。我非常确信 Transfer Utility 也在运行一项服务。

Handler (android.os.Handler) {11629d87} sending message to a Handler on a dead thread
    java.lang.IllegalStateException: Handler (android.os.Handler) {11629d87} sending message to a Handler on a dead thread
    at android.os.MessageQueue.enqueueMessage(MessageQueue.java:325)
    at android.os.Handler.enqueueMessage(Handler.java:631)
    at android.os.Handler.sendMessageAtTime(Handler.java:600)
    at android.os.Handler.sendMessageDelayed(Handler.java:570)
    at sksDoneLater(TransferService.java:189)
    at com.amazonaws.mobileconnectors.s3.transferutility.TransferService.access$200(TransferService.java:44)
    at com.amazonaws.mobileconnectors.s3.transferutility.TransferService$2.handleMessage(TransferService.java:166)
    at android.os.Handler.dispatchMessage(Handler.java:98)
    at android.os.Looper.loop(Looper.java:135)
    at android.os.HandlerThread.run(HandlerThread.java:61)

这是我用来启动它的代码：

    AmazonS3 amazonS3 = new AmazonS3Client(credentialsProvider);
    mTransferUtility = new TransferUtility(amazonS3, getApplicationContext());
    TransferObserver observer = mTransferUtility.upload(
            S3_RAW_BUCKET_ARN,
            mVidFileKey,
            mVidFile);

    observer.setTransferListener(new TransferListener() {...})

前一行说它无法获取 s3 客户端。我在应用程序类中创建了如上所示的客户端，并成功地在活动中使用相同的代码来执行成功的传输，因此对于我不了解的服务必须是显而易见的。上面的代码是在服务中从onStartCommand()调用的方法中调用的。

任何帮助将不胜感激。

更新 - 请求全班并在此处显示：

public class VideoCompressionService extends Service {;

private Bus bus;
private TransferUtility mTransferUtility;
private int mVidWidth;
private int mVidHeight;
private File mCompressedVidFile;
private File mVidFile;
private String mVidFileKey;
private NotificationManager mNotificationManager;
private android.support.v4.app.NotificationCompat.Builder mNotification;

public VideoCompressionService() {

}

@Override
public int onStartCommand(Intent intent, int flags, int startId) {
    if (intent != null) {
        String realPath = MediaUtils.getRealVideoPathFromURI(this.getContentResolver(), intent.getData());
        if (realPath != null) {
            this.mVidFile = new File(realPath);
            this.mVidFileKey = intent.getStringExtra(EXTRA_VID_FILE_KEY);
            this.mVidWidth = intent.getIntExtra(EXTRA_VID_WIDTH, 0);
            this.mVidHeight = intent.getIntExtra(EXTRA_VID_HEIGHT, 0);
            this.bus = CoPhotoApplication.getVideoCompressionBus();
            if (mVidFile != null && mVidFile.exists() && mVidFile.canRead()) {
                mNotificationManager = (NotificationManager) this.getSystemService(Context.NOTIFICATION_SERVICE);
                mNotification = new NotificationCompat.Builder(this)
                        .setContentTitle("Compressing Video - Step 1 of 3")
                        .setContentText("Uploading video for processing...")
                        .setSmallIcon(R.drawable.ic_launcher);
                if (mVidWidth == 0 || mVidHeight == 0) {
                    MediaMetadataRetriever mmr = new MediaMetadataRetriever();
                    mmr.setDataSource(mVidFile.getAbsolutePath());
                    mVidWidth = Integer.parseInt(mmr.extractMetadata(MediaMetadataRetriever.METADATA_KEY_VIDEO_WIDTH));
                    mVidHeight = Integer.parseInt(mmr.extractMetadata(MediaMetadataRetriever.METADATA_KEY_VIDEO_HEIGHT));
                    mmr.release();
                }
                uploadVidToS3();
            }
            return Service.START_NOT_STICKY;
        } else {
            VideoCompressionService.this.stopSelf();
            return Service.START_NOT_STICKY;
        }
    } else {
        VideoCompressionService.this.stopSelf();
        return Service.START_NOT_STICKY;
    }
}

@Nullable
@Override
public IBinder onBind(Intent intent) {
    return null;
}

private void uploadVidToS3() {
    compressionUploadStarted();
    CognitoCachingCredentialsProvider credentialsProvider = new CognitoCachingCredentialsProvider(
            getApplicationContext(),
            "*********ID HERE********", // Identity Pool ID
            Regions.US_EAST_1 // Region
    );

    AmazonS3 amazonS3 = new AmazonS3Client(credentialsProvider);
    mTransferUtility = new TransferUtility(amazonS3, getApplicationContext());
    TransferObserver observer = mTransferUtility.upload(
            S3_RAW_BUCKET_ARN,
            mVidFileKey,
            mVidFile);

    observer.setTransferListener(new TransferListener() {
        @Override
        public void onStateChanged(int id, TransferState state) {
            if (state == TransferState.COMPLETED) {
                compressionUploadFinished(true);
                zencodeVideo(mVidFileKey);
            } else if (state == TransferState.FAILED) {
                compressionUploadFinished(false);
            }
        }

        @Override
        public void onProgressChanged(int id, long bytesCurrent, long bytesTotal) {
            int progress = Math.round(100 * ((float) bytesCurrent / bytesTotal));
            String progressPercentage = String.valueOf(progress) + "%";
            compressionUploadProgress(progress, progressPercentage);
        }

        @Override
        public void onError(int id, Exception ex) {
            compressionUploadFinished(false);
        }
    });
}

private void compressionUploadStarted() {
    bus.post(new CompressionUploadStartedEvent());
    updateNotification();
}

private void compressionUploadProgress(int progress, String progressPercentage) {
    bus.post(new CompressionUploadProgressEvent(progress, progressPercentage));
    mNotification.setProgress(100, progress, false);
    updateNotification();
}

private void compressionUploadFinished(boolean successfully) {
    bus.post(new CompressionUploadFinishedEvent(successfully));
    if (successfully) {
        mNotification.setContentText("Upload complete");
    } else {
        mNotification.setContentTitle("Compression Failed");
        mNotification.setContentText("Upload failed. Please try again later.");
    }
    updateNotification();
    if (!successfully) {
        VideoCompressionService.this.stopSelf();
    }
}

private void updateNotification() {
    mNotificationManager.notify(NOTIFICATION_ID, mNotification.build());
}

Answer 1

我发现自己遇到了同样的问题... 这就是为我解决的问题：

我注意到我在 Manifest 中为我的 SyncAdapter 注册了以下服务：

        <service
        android:name=".sync.SyncService"
        android:exported="true"
        android:process=":sync">
        <intent-filter>
            <action android:name="android.content.SyncAdapter"/>
        </intent-filter>
        <meta-data android:name="android.content.SyncAdapter"
            android:resource="@xml/syncadapter" />
    </service>

android:process=":sync" 告诉服务在一个名为 :sync 的私有进程中运行 所以我只是告诉 Amazon SDK 的 TransferService 在同一个线程中运行。

        <service
        android:name="com.amazonaws.mobileconnectors.s3.transferutility.TransferService"
        android:process=":sync"
        android:enabled="true" />

之后，我再没有收到错误TransferService can't get s3 client, and it will stop，终于可以将我的图片上传到S3

Answer 2

您应该将客户端声明为全局变量，因为如果您不这样做，垃圾收集器可能会删除它。