import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
public SofaMessageReceiver(@NonNull final HDWallet wallet,
                           @NonNull final ProtocolStore protocolStore,
                           @NonNull final ConversationStore conversationStore,
                           @NonNull final SignalServiceUrl[] urls,
                           @NonNull final SofaMessageSender messageSender) {
    this.wallet = wallet;
    this.protocolStore = protocolStore;
    this.messageReceiver =
            new SignalServiceMessageReceiver(
                    new SignalServiceConfiguration(urls, new SignalCdnUrl[0]),
                    this.wallet.getOwnerAddress(),
                    this.protocolStore.getPassword(),
                    this.protocolStore.getSignalingKey(),
                    USER_AGENT);

    this.taskGroupUpdate = new GroupUpdateTask(this.messageReceiver, messageSender, conversationStore);
    this.taskHandleMessage = new HandleMessageTask(this.messageReceiver, conversationStore, this.wallet, messageSender);
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
private @Nullable static File writeAttachmentToFileFromMessageReceiver(
        final SignalServiceAttachmentPointer attachment,
        final SignalServiceMessageReceiver messageReceiver,
        final String fileId) {
    File file = null;
    try {
        final String tempName = String.format("%d", attachment.getId());
        file = new File(BaseApplication.get().getCacheDir(), tempName);
        final int maxFileSize = 20 * 1024 * 1024;
        final InputStream inputStream = messageReceiver.retrieveAttachment(attachment, file, maxFileSize);

        final File destFile = constructAttachmentFile(attachment.getContentType(), fileId);
        return writeToFileFromInputStream(destFile, inputStream);
    } catch (IOException | InvalidMessageException e) {
        LogUtil.exception(FileUtil.class, "Error during writing attachment to file", e);
        return null;
    } finally {
        if (file != null) {
            file.delete();
        }
    }
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
@Override
public void onRun() throws IOException {
  receiver.retrieveMessages(new SignalServiceMessageReceiver.MessageReceivedCallback() {
    @Override
    public void onMessage(SignalServiceEnvelope envelope) {
      handle(envelope, false);
    }
  });
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
public static Single<Avatar> processFromSignalGroup(final SignalServiceGroup group, final SignalServiceMessageReceiver messageReceiver) {
    if (group.getAvatar().isPresent()) {
        return Single.fromCallable(() -> {
            final SignalServiceAttachmentPointer attachment = group.getAvatar().get().asPointer();
            final String groupId = Hex.toHexString(group.getGroupId());
            return FileUtil.writeAvatarToFileFromMessageReceiver(attachment, messageReceiver, groupId);
        })
        .flatMap(Avatar::compressImage)
        .map(File::getAbsolutePath)
        .map(BitmapFactory::decodeFile)
        .map(Avatar::new);
    }

    return Single.just(new Avatar());
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
private InputStream retrieveAttachmentAsStream(SignalServiceAttachmentPointer pointer, File tmpFile) throws IOException, InvalidMessageException {
    final SignalServiceMessageReceiver messageReceiver = new SignalServiceMessageReceiver(serviceUrls, localIdentity.getToshiId(), localIdentity.getPassword(), Base64.encodeBytes(localIdentity.getSignalingKey()), USER_AGENT);
    return messageReceiver.retrieveAttachment(pointer, tmpFile, MAX_ATTACHEMENT_SIZE_BYTES);
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
@Provides SignalServiceMessageReceiver provideSignalMessageReceiver() {
  return new SignalServiceMessageReceiver(networkAccess.getConfiguration(context),
                                          new DynamicCredentialsProvider(context),
                                          BuildConfig.USER_AGENT);
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
public @Nullable static File writeAvatarToFileFromMessageReceiver(
        final SignalServiceAttachmentPointer attachment,
        final SignalServiceMessageReceiver messageReceiver,
        final String groupId) {
    return writeAttachmentToFileFromMessageReceiver(attachment, messageReceiver, groupId);
}
 

import org.whispersystems.signalservice.api.SignalServiceMessageReceiver; //导入依赖的package包/类
private InputStream retrieveAttachmentAsStream(SignalServiceAttachmentPointer pointer, File tmpFile) throws IOException, InvalidMessageException {
    final SignalServiceMessageReceiver messageReceiver = new SignalServiceMessageReceiver(serviceConfiguration, username, password, deviceId, signalingKey, USER_AGENT, null);
    return messageReceiver.retrieveAttachment(pointer, tmpFile, MAX_ATTACHMENT_SIZE);
}