阅读视图

发现新文章,点击刷新页面。

基于 WordPress 开源的 AztecEditor-iOS库实现原生富文本编辑器

AztecEditor-iOS 基于 UITextView 提供了一个性能良好的用户界面组件。Android 端有对应的 SDK。

它由两个主要部分组成:

  • TextView:用户界面组件,用于呈现和编辑内容,可预览文本展示样式和对应HTML。
  • 转换器:实现HTML 和 NSAttributedString 的相互转换。

Aztec提供了丰富的富文本编辑功能,包括字体格式化(粗体、斜体、下划线、删除线、颜色等),引用块(可自定义样式),媒体文件(图片、视频)的展示和编辑,自定义标签(包括但不限于@、#等特殊字符可触发的自定义功能)等等。

鉴于 Aztec 的官方文档相当的简洁,开发者使用起来并没有那么方便,编者在实现编辑器的过程当中主要是参考了官方Demo

这里不针对 Aztec 源码做过多解析,只对如何使用以及如何进行定制化功能做一些说明,都是笔者在实际开发当中使用到的。

插件和短码系统

Aztec 提供的插件和短码系统,可以让我们通过自定义插件和短码来实现定制功能。

插件的实现主要是基于Plugin类和Processor协议,搭配短码解析系统来进行功能定制。短码方案直接采用了 WordPress-Editor 的方案,这个方案主要由ShortcodeAttributeSerializerShortcodeProcessorHTMLProcessor组成,ShortcodeProcessor内部通过正则匹配,可以识别形如[tag id="" type="" content=""]的自定义短码,搭配ShortcodeAttributeSerializerHTMLProcessor来进行正反方向的解析。

基于 Aztec 的插件和短码系统,我们可以扩展出用于自己项目的HTML与富文本相互转换的完全定制化系统,实际上 WordPress-Editor 的 Demo 就是这么做的。

image

open class Plugin {

    // MARK: - Customizers

    public let inputCustomizer: PluginInputCustomizer?
    public let outputCustomizer: PluginOutputCustomizer?

    // MARK: - Initializers

    public init(inputCustomizer: PluginInputCustomizer? = nil, outputCustomizer: PluginOutputCustomizer? = nil) {
        self.inputCustomizer = inputCustomizer
        self.outputCustomizer = outputCustomizer
    }

    /// Method plugins can use to execute extra code when loaded.

    ///
    open func loaded(textView: TextView) {}

  

    // MARK: - Equatable

    public static func ==(lhs: Plugin, rhs: Plugin) -> Bool {
        return type(of: lhs) == type(of: rhs)
    }
}

插件的功能主要依靠PluginInputCustomizerPluginOutputCustomizer来实现。我们在初始化编辑器时进行加载即可。

let plugins = [RichEditorPlugin(), PasteboardPlugin()]
for plugin in plugins {
    textView.load(plugin)
}
/// PluginInputCustomizer定义
public protocol PluginInputCustomizer {
    func process(html: String) -> String
    func process(htmlTree: RootNode)
    func converter(for elementNode: ElementNode) -> ElementConverter?
}

/// PluginOutputCustomizer定义
public protocol PluginOutputCustomizer {
    func process(html: String) -> String
    func process(htmlTree: RootNode)
    func convert(_ paragraphProperty: ParagraphProperty) -> ElementNode?
    func convert(_ attachment: NSTextAttachment, attributes: [NSAttributedString.Key: Any]) -> [Node]?
    func converter(for elementNode: ElementNode) -> ElementToTagConverter?
}

PluginInputCustomizer 可以和短码系统组合来为输入过程提供操作 HTML 的函数。 PluginOutputCustomizer为输出过程提供操作 HTML 的函数。比如发布时,自定义输出 HTML 内容。

在获取 HTML 时,Aztec 会调用HTMLConverterhtml(from attributedString: NSAttributedString, prettify: Bool = false) -> String函数来进行解析,将富文本转换成 HTML。

其内部借助 AttributedStringParser 和 ElementConverter(如ImageAttachmentToElementConverterVideoAttachmentToElementConverter)生成节点树,再通过HTMLSerializerserialize(_ node: Node, prettify: Bool = false) -> String函数,将节点树处理成 HTML,以上过程的每个节点都可以通过遵循PluginOutputCustomizer来进行干预。

class RichEditorPlugin: Plugin {
    init() {
        super.init(inputCustomizer: EditorInputCustomizer(),
                   outputCustomizer: EditorOutputCustomizer())
    }
}


class EditorInputCustomizer: PluginInputCustomizer {

    private var processor: PipelineProcessor = {

        var processors = [VideoProcessor.previewProcessor, ImageProcessor.previewProcessor]

        processors.append(contentsOf: CustomTagType.previewProcessors)
        return PipelineProcessor(processors)
    }()

  

    func process(html: String) -> String {
        return processor.process(html)
    }

    func process(htmlTree: Aztec.RootNode) {}
  
    func converter(for elementNode: Aztec.ElementNode) -> (any Aztec.ElementConverter)? {
        return nil
    }
}
class EditorOutputCustomizer: PluginOutputCustomizer {

    private var processor: PipelineProcessor = {
        var processors = [VideoProcessor.postProcessor, ImageProcessor.postProcessor]
        processors.append(contentsOf: CustomTagType.postProcessors)
        return PipelineProcessor(processors)
    }()

    func process(html: String) -> String {
        return processor.process(html)
    }

    func process(htmlTree: Aztec.RootNode) {}
  
    func convert(_ paragraphProperty: Aztec.ParagraphProperty) -> Aztec.ElementNode? {
        return nil
    }

    func convert(_ attachment: NSTextAttachment, attributes: [NSAttributedString.Key: Any]) -> [Aztec.Node]? {
        return nil
    }

    func converter(for elementNode: Aztec.ElementNode) -> (any Aztec.ElementToTagConverter)? {
        return nil
    }
}

文本格式化

工具条

Aztec 提供了工具条FormatBarFormatBarItem,在其基础上可做一些有限的自定义。

image

在实际开发中,开发者可以使用完全自定义的 UI + Aztec 提供的功能。

文本格式化

实现字体样式改变,比如粗体、斜体、下划线、删除线、引用块、标题可以直接调用 Aztec 提供的函数。插入自定义高亮标签,如 @someone 将在下一节进行说明。

private func handleFormat(_ style: EditorToolType.FormatFontStyle) {
        switch style {
        case .bold: /// 粗体文本
            richTextView.toggleBold(range: richTextView.selectedRange)
        case .italic: /// 斜体文本
            richTextView.toggleItalic(range: richTextView.selectedRange)
        case .underline: /// 下划线
            richTextView.toggleUnderline(range: richTextView.selectedRange)
        case .strikethrough: /// 删除线
            richTextView.toggleStrikethrough(range: richTextView.selectedRange)
        case .blockQuote: /// 引用块
            richTextView.toggleBlockquote(range: richTextView.selectedRange)
        case .headline: /// 标题
            richTextView.toggleHeader(.h1, range: richTextView.selectedRange)
        case .link: /// 添加链接
            delegate?.shouldInsertLink(self)
        case .horizontalRule: /// 分割线
            richTextView.replaceWithHorizontalRuler(at: richTextView.selectedRange)
        default:
            break
        }
    }

实现的样式如下:

image

插入自定义标签

在我们项目当中,自定义标签各端约定了固定格式,比如固定格式可以是这样的:[[id, type, content]]。通过插件和短码系统,编写自定义的短码处理器,可以完美实现需求。

短码的构造和解析

ShortcodeAttributeSerializerHTMLProcessor组合可以将短码解析为 HTML,我们可以在解析过程中自定义 HTML 的内容,保证在编辑器中展示正确的样式。

    static func parsedCustomTag(_ entity: CustomTagEntity) -> String {
      /// 构造符合ShortcodeProcessor要求格式的短码, e.g. [mention type=\"1\" text=\"@iOS test\" id=\"123\"]
        let shortCode = "[\(entity.type.identifier) type=\"\(entity.type.rawValue)\" text=\"\(entity.text)\" id=\"\(entity.id)\"]"
      /// 构造处理器
        let process = CustomTagsProcessor(tagType: entity.type)
      /// 将短码解析成 HTML
        return process.previewProcessor.process(shortCode)
    }

var previewProcessor: Processor {
        let serializer = ShortcodeAttributeSerializer()
        let processor = ShortcodeProcessor(tag: tagType.identifier) { shortCode in
            var html = "<mark style=\"color: #007AF5;\""

            guard let type = shortCode.attributes["type"],
                  let text = shortCode.attributes["text"],
                  let id = shortCode.attributes["id"]
            else {
                return nil
            }

            html += serializer.serialize(key: "type", value: type.value) + " "
            html += serializer.serialize(key: "text", value: text.value) + " "
            html += serializer.serialize(key: "id", value: id.value) + " "
            html += ">\(serializer.serialize(text.value))</mark>;
            return html
        }
        return processor
    }

HTML转自定义标签

ShortcodeAttributeSerializerShortcodeProcessor组合可以将 HTML 转为 自定义标签

在编辑器中展示时,为了方便previewProcessor使用了 mark 来标记自定义标签,所以在postProcessor中要使用HTMLProcessor找到 mark 标签进行解析。 Aztec 支持未知标签,底层将未知标签转换成 NSTextAttachment 的子类,实现该功能需要自定义 Attachment 和 Render,下面会讲到。

    var postProcessor: Processor {
        let serializer = ShortcodeAttributeSerializer()
        let processor = HTMLProcessor(for: Element.mark.rawValue) { element in
            guard let type = element.attributes["type"],
                  let text = element.attributes["text"],
                  let id = element.attributes["id"]
            else { return nil }
  
            let html = String(format: "[[%@,%@,%@]]", serializer.serialize(type.value), serializer.serialize(text.value), serializer.serialize(id.value))
            return html
        }
        return processor
    }

使用方法

基于上面的实现,统一了插入自定义标签的方法

enum CustomTagType: Int, CaseIterable {
    case mention = 1
    case link = 2
    case other = 3
    
    var identifier: String {
        switch self {
        case .mention: return "mention"
        case .link: return "link"
        case .other: return "other"
        }

    }

    static var previewProcessors: [Processor] {
        let processors = CustomTagType.allCases.map { CustomTagsProcessor(tagType: $0).previewProcessor }
        return processors
    }

    static var postProcessors: [Processor] {
        let processors = CustomTagType.allCases.map { CustomTagsProcessor(tagType: $0).postProcessor }
        return processors
    }
}

插入时按照上面提供的方案来进行即可。比如插入@someone:我们按照给定的格式提供一个短码 [mention type=\"1\" text=\"@iOS test\" id=\"123\"],经过previewProcessor的处理后会得到如下 HTML,这样可以保证在编辑器中的正确展示。 

<mark style=\"color: #007AF5;\" type=\"1\" text=\"@iOS test\" id=\"123\" >@iOS test</mark>;

上面的 HTML 经过postProcessor的处理后会得到约定好的自定义标签的固定格式[[1,@iOS test,123]],这样可以保证发布时得到正确的内容。

自定义未知HTML标签

Aztec 支持未知HTML标签,其原理是将未知标签转换成 NSTextAttachment 的子类,所以要实现该功能就需要自定义 Attachment 和 Render。

Attachment用来表示未知标签,Render 用来保证正确渲染。Aztec 为我们提供了 HTMLAttachment 和HTMLAttachmentRenderer,但它们可能无法满足我们的需求,所以在使用时需要做定制。

下面是我们的自定义渲染器:

class CustomTagsRender: TextViewAttachmentImageProvider {
    func textView(_ textView: TextView, shouldRender attachment: NSTextAttachment) -> Bool {
        return attachment is HTMLAttachment
    }

    func textView(_ textView: TextView, imageFor attachment: NSTextAttachment, with size: CGSize) -> UIImage? {
        UIGraphicsBeginImageContextWithOptions(size, false, 0)

        guard let attachment = attachment as? HTMLAttachment else {
            return nil
        }

        let message = messageAttributedString(with: attachment)
        let targetRect = boundingRect(for: message, size: size)

        message.draw(in: targetRect)

        let result = UIGraphicsGetImageFromCurrentImageContext()
        UIGraphicsEndImageContext()

        return result
    }

    func textView(_ textView: TextView, boundsFor attachment: NSTextAttachment, with lineFragment: CGRect) -> CGRect {
        guard let attachment = attachment as? HTMLAttachment else {
            return .zero
        }

        let message = messageAttributedString(with: attachment)

        let size = CGSize(width: lineFragment.size.width, height: lineFragment.size.height)
        var rect = boundingRect(for: message, size: size)
        rect.origin.y = UIFont.mainRegular(size: 16).descender

        return rect.integral
    }
}

private extension CustomTagsRender {
    private func boundingRect(for message: NSAttributedString, size: CGSize) -> CGRect {
        let targetBounds = message.boundingRect(with: size, options: [.usesLineFragmentOrigin, .usesFontLeading], context: nil)
        let targetPosition = CGPoint(x: (size.width - targetBounds.width) * 0.5, y: (size.height - targetBounds.height) * 0.5)

        return CGRect(origin: targetPosition, size: targetBounds.size)
    }

    private func messageAttributedString(with attachment: HTMLAttachment) -> NSAttributedString {
        let attributes: [NSAttributedString.Key: Any] = [
            .foregroundColor: UIColor.textLink,
            .font: UIFont.mainRegular(size: 16)
        ]
/// 此处的 tagName 必须与 previewProcessor 和 postProcessor 中使用的标签名一致!!!
        guard let text = extractContent(from: attachment.rawHTML, tagName: "test")
        else {
            return NSAttributedString(string: "[Unknown]", attributes: attributes)
        }
        return NSAttributedString(string: text, attributes: attributes)
    }

    private func extractContent(from html: String, tagName: String) -> String? {
        do {
            let document = try SwiftSoup.parse(html)
            let elements = try document.getElementsByTag(tagName)

            if let element = elements.first() {
                let content = try element.text()
                return content
            }
        } catch {
            print("HTML 解析错误: \(error)")
        }

        return nil
    }
}

效果展示:

image

使用该方案可以一键删除 attachment,不支持光标移入,而且 attachment 支持点击,可以做一些扩展操作。缺点就是存在换行展示问题。

插入图片、视频

对于图像、视频、分隔符和表格等嵌入元素,使用的是NSTextAttachment的子类:

插入图片和视频时采用下面的方法,等待上传完成后,通过 identifier 获取对应 attachment,替换必要数据即可。

replaceWithImage(at range: NSRange, sourceURL url: URL, placeHolderImage: UIImage?, identifier: String = UUID().uuidString) -> ImageAttachment

replaceWithVideo(at range: NSRange, sourceURL: URL, posterURL: URL?, placeHolderImage: UIImage?, identifier: String = UUID().uuidString) -> VideoAttachment

图片、视频的自定义属性

Aztec 提供的 Attachment 的属性可能无法满足我们的需求,比如项目需要保留标志视频长度的data-duration属性,这个 Aztec 并没有提供。

幸运的是 Aztec 为我们提供了extraAttributes字段,并且支持通过对extraAttributes进行解析来实现添加任意属性的功能。

    func convert(_ attachment: VideoAttachment, attributes: [NSAttributedString.Key : Any]) -> [Node] {
        let element: ElementNode
        
        ...
        /// 这里将extraAttributes中的自定义属性附加到了 element 上
        for attribute in attachment.extraAttributes {
            element.updateAttribute(named: attribute.name, value: attribute.value)
        }

        element.children = element.children + videoSourceElements(from: attachment)

        return [element]
    }

我们为 VideoAttachment 扩展了自定义属性,然后利用extraAttributes来实现我们的需求,使用时为自定义属性赋值,并在 processor 中进行解析。

extension VideoAttachment {

    @objc var videoId: String? {
        get {
            return extraAttributes[MediaHTMLAttribute.videoAttribute]?.toString()
        }
        set {
            if let nonNilValue = newValue {
                extraAttributes[MediaHTMLAttribute.videoAttribute] = .string(nonNilValue)
            } else {
                extraAttributes.remove(named: MediaHTMLAttribute.videoAttribute)
            }
        }
    }

    var duration: String? {
        get {
            return extraAttributes[MediaHTMLAttribute.videoDuration]?.toString()
        }
        set {
            if let nonNilValue = newValue {
                extraAttributes[MediaHTMLAttribute.videoDuration] = .string(nonNilValue)
            } else {
                extraAttributes.remove(named: MediaHTMLAttribute.videoDuration)
            }
        }
    }
}

图片和视频 processor 输出 HTML 的代码如下:

    static var postProcessor: Processor {
        let serializer = ShortcodeAttributeSerializer()
        let processor = HTMLProcessor(for: "img", replacer: { element in
            var html = "<img "
            if let imgId = element.attributes[MediaAttachment.uploadKey] {
                html += "\(serializer.serialize(key: "id", value: imgId.value))" + " "
            }
            if let src = element.attributes["src"] {
                html += "\(serializer.serialize(key: "src", value: src.value))" + " "
            }

            html += ">"
            return html
        })
        return processor
    }

    static var postProcessor: Processor {
        let serializer = ShortcodeAttributeSerializer()
        let processor = HTMLProcessor(for: "video", replacer: { element in
            var html = "<video "
            if let videoId = element.attributes[MediaAttachment.uploadKey] {
                html += "\(serializer.serialize(key: "id", value: videoId.value))" + " "
            }

            if let src = element.attributes["src"] {
                html += "\(serializer.serialize(key: "src", value: src.value))" + " "
            }

            if let width = element.attributes["width"] {
                html += "\(serializer.serialize(key: "w", value: width.value))" + " "
            }

            if let height = element.attributes["height"] {
                html += "\(serializer.serialize(key: "h", value: height.value))" + " "
            }

            if let posterAttribute = element.attributes["poster"],
               case let .string(posterValue) = posterAttribute.value,
               let posterURL = URL(string: posterValue),
               !posterURL.isFileURL
            {
                html += serializer.serialize(posterAttribute) + " "
            }

            if let duration = element.attributes["duration"] {
                html += "\(serializer.serialize(key: "data-duration", value: duration.value))" + " "
            }

            html += ">"
            return html
        })
        return processor
    }

总结

Aztec能够实现的功能远不止上面介绍到的,它还可以实现列表、自定义引用块、自定义媒体文件展示样式等等,这些功能需要开发者在自行探究中进行持续的发掘。

Combine:订阅、绑定和内存管理

我正在参加「掘金·启航计划」

sink

sink负责订阅Publisher,并返回一个AnyCancellabel

完整签名:

 public func sink(receiveCompletion: @escaping ((Subscribers.Completion<Self.Failure>) -> Void), receiveValue: @escaping ((Self.Output) -> Void)) -> AnyCancellable

它接受两个闭包回调做为参数,receiveCompletion 在发布结束事件时被调用,receiveValue 在发布值时被调用。

来自喵神《SwiftUI和Combine编程》中的发布-订阅流程图:

iShot_2023-04-28_17.35.40.png

在使用 sink 完成订阅时,会创建一个特殊的 Subscriber 类型 Subscribers.Sink,并被纳入上面的流程中。它会自动声明想要接收无限多个新值,并订阅相应的 Publisher 对象。接下来,Publisher 会将新的值和结束事件作为参数传递给 sink 传入的两个闭包,从而将响应式的事件流转化为普通的指令操作。

Backpressure(背压)

Subscriber 可以在订阅初期通过 Subscription.request 或者通过 Subscriber.receive 返回特定的 Subscribers.Demand 值来指定能够处理的值的个数。这种背压机制 (Backpressure),可以让我们指定合适的背压策略,来控制可接收的值的上限,防止出现上游的发布速度超过下游消费速度的问题。

assign

Combine内建的另一个Subscriber就是assign,它可以用来将 Publisher 的输出值通过 key path 绑定到一个对象的属性上去。

使用assign时有几点需要注意的地方:

  1. 只有 class 上用 var 声明的属性才可以通过 assign 来直接赋值

  2. 上游 Publisher 的 Failure 的类型必须是 Never。如果上游 Publisher 可能会发生错误,必须先对它进行处理,比如使用 replaceError或者 catch 来把错误在绑定之前就处理掉。

  3. 核心概念 中已经有过说明,使用 assign(to:on:) 并存储生成的 AnyCancellable,可能会引起引用循环,所以请尽量使用assign(to:)来替代assign(to:on:)

引用共享

一个Publisher可能会有多个Subscriber,如果这个Publisher是一个网络请求的话,由于 dataTaskPublisher 是Struct,遵循值语义,多次订阅会复制多份,每一份都是一个新的Publisher,而这会造成多次请求,这是很浪费资源的。

解决上面问题的方法就是使用share()来共享Publisher。share()操作会把原来的Publisher包装到class内,对它的进一步变形也会适用于引用语义。

Cancellable & AnyCancellable

使用sink或者assign订阅Publisher时,会返回一个类型为AnyCancellable类型的值;而Timer在执行connect()操作后得到的是一个遵循Cancellable协议的值。

对于 Cancellable 来说,需要在合适的时候主动调用 cancel() 方法来完结。如果在没有调用 cancel() 的情况下就将 connect 的返回值忽略或者释放掉,那么Timer会一直计时,永远不会被终结掉。所以对于需要connect的Publisher,需要显式的调用cancel()来结束事件。

AnyCancellable 是一个 class,它可以对自身的生命周期进行管理。在 AnyCancellable 被释放时,它对应的订阅操作也会停止。

在应用中,我们会在实例当中创建一个Set<AnyCancellable>存储属性,并将sink或者assign返回的AnyCancellable存储其中。这样,当该实例 deinit 时,AnyCancellable 的 deinit 也会触发,并自动释放资源。这跟 RxSwift 中的 DisposeBag 很类似。

参考

王巍 《SwiftUI和Combine编程》

Combine:错误处理

Publisher的结束事件有两种可能:代表正常完成的.finished和代表发生错误的.failure

Subscriber在订阅上游Publisher时,Combine要求Publisher.outputSubscriber.input的类型一致,同时也要求所接受的Failure的类型一致,否则就算Publisher只发出Output值,也无法使用这个Subscriber去接收。

这种设计提醒我们,在开发中要充分考虑对可能出现的错误的处理。

转换错误类型

enum RequestError: Error {
    case sessionError(error: Error)
}
let imageURLPublisher = PassthroughSubject<URL, RequestError>()
imageURLPublisher.flatMap { url in
    return URLSession.shared.dataTaskPublisher(for: url).map { _ in
        
    }
 }

这段代码会抛出一个错误,明确告诉我们RequestError和URLError的类型不一致:

candidate requires that the types 'RequestError' and 'URLSession.DataTaskPublisher.Failure' (aka 'URLError') be equivalent (requirement specified as 'Self.Failure' == 'P.Failure')

此时,使用mapError进行类型转换非常合适

let cancellable = imageURLPublisher.flatMap { requestURL in
    return URLSession.shared.dataTaskPublisher(for: requestURL)
        .mapError { error -> RequestError in
            return RequestError.sessionError(error: error)
        }
}.sink(receiveCompletion: { (error) in
    print("请求失败: \(String(describing: error))")
}, receiveValue: { (result) in
    let image = UIImage(data: result.data)
    print("请求成功: \(image?.description ?? "")")
})

imageURLPublisher.send(URL(string: "https://httpbin.org/image/jpeg")!)
imageURLPublisher.send(URL(string: "https://unknown.url/image")!)

两次send得到的结果如下:

请求成功: <UIImage:0x60000395d290 anonymous {239, 178} renderingMode=automatic(original)>
请求失败: failure(__lldb_expr_9.RequestError.sessionError(error: Error Domain=NSURLErrorDomain Code=-1200 "An SSL error has occurred and a secure connection to the server cannot be made."

抛出错误

Combine 为 Publisher 的 map 操作提供了一个可以抛出错误的版本:tryMap。使用 tryMap 我们就可以将处理数据时发生的错误,转变为标志事件流失败的结束事件:

["1", "2", "Swift", "4"].publisher
    .tryMap { s -> Int in
        guard let value = Int(s) else {
            throw IntError.typeError
        }
        return value
    }.print()
    .sink { _ in } receiveValue: { _ in }

输出的结果是:

receive subscription: (TryMap)
request unlimited
receive value: (1)
receive value: (2)
receive error: (typeError)

"Swift" 字符串是无法被转换为 Int 值的,使用tryMap就将这个错误抛了出来,导致整个事件流以错误结果终止,接下来的 "4" 也不再会被处理。

除了 tryMap 以外,Combine 中还有很多类似的以 try 开头的操作符,比如 tryScantryFiltertryReduce 等等。当需要在数据转换或者处理时,将事件流以错误进行终止,都可以使用对应操作的 try 版本来进行抛出,并在订阅者一侧接收到对应的错误事件。这些try*工作的思路是一致的。

从错误中恢复

开发中遇到不需要将错误信息反馈给用户的情况时,我们可以选择使用默认值来让事件流从错误中“恢复”的方式来处理。

在 Combine 里,有一些 Operator 是专门做这种处理的,比如 replaceErrorcatch。代码始终是最直观的说明方式。

使用replaceError

["1", "2", "Swift", "4"].publisher
    .tryMap { s -> Int in
        guard let value = Int(s) else {
            throw IntError.typeError
        }
        return value
    }
    .replaceError(with: -1)
    .print()
    .sink { _ in
    } receiveValue: { _ in
    }

/// 输出结果
//receive subscription: (ReplaceError)
//request unlimited
//receive value: (1)
//receive value: (2)
//receive value: (-1)
//receive finished

使用catch

["1", "2", "Swift", "4"].publisher
    .tryMap { s -> Int in
        guard let value = Int(s) else {
            throw IntError.typeError
        }
        return value
    }
    .catch { _ in
        Just(-1)
    }
    .print()
    .sink { _ in
    } receiveValue: { _ in
    }
/// 输出结果
//receive subscription: (Catch)
//request unlimited
//receive value: (1)
//receive value: (2)
//receive value: (-1)
//receive finished

两种方式的打印结果是相同的,但是实现的方式却不一样:

1. replaceError是使用单个值替换出错的值

2. catch将产生错误的publisher替换为了一个全新的publisher

这两种方式都可以实现错误替换,但是它们都在发生错误的地方中断了整个事件流,在开发中,这往往不是我们想要的结果。这种状态要怎么解决呢?我们可以组合使用一些操作符来达成目的。

["1", "2", "Swift", "4"].publisher
    .flatMap { s in
        Just(s)
            .tryMap { s -> Int in
                guard let value = Int(s) else {
                    throw IntError.typeError
                }
                return value
            }
            .catch { _ in
                Just(-1)
            }
    }
    .print()
    .sink { _ in
    } receiveValue: { _ in
    }
/// 输出结果
//receive subscription: (FlatMap)
//request unlimited
//receive value: (1)
//receive value: (2)
//receive value: (-1)
//receive value: (4)
//receive finished

在响应式异步编程中,使用 flatMap 进行“包装”的手法是很常见的。这样即使发生了 类似例子当中的"Swift" 无法转换为 Int 的错误,最终的 "4" 依然可以得到正确的处理。

Combine:核心概念

只要理解了这三个核心概念,你就可以很好的使用Combine,所以从这个角度来说,我们可以将Combine简单的理解为下面的形式: Combine = Publishers + Operators +

Combine: 概览

你可以使用Combine为给定的事件创建单个处理链,而不用实现多个委托或者闭包回调。处理链的每个部分都是一个Combine操作符,用来对从上一步接收到的元素执行不同的操作。

Combine: Debugging

理解异步代码中的事件流,对于初学者来说一直是一个挑战。在Combine的上下文中尤其如此,因为事件流中的操作符链可能不会立即发出事件。

UITableView 性能优化

我正在参加「掘金·启航计划」

UITableView 的加载原理

可变高的列表载体 Cell 是在开发中经常处理到的一个技术点。 UITableViewCell 的高度需要在数据源代理中设置:

-(CGFloat)tableView:(UITableView *)tableView heightForRowAtIndexPath:(NSIndexPath *)indexPath{
return height;
}

heightForRowAtIndexPath方法会重复执行很多次,并且heightForRowAtIndexPath 方法的执行机制在不同版本 iOS 系统中还会有很大不同。在 iOS 11 中,默认已经采取了一些优化手段。

在 iOS 9上,要显示一行 cell,至少要执行 5 遍heightForRowAtIndexPath 方法:

  • UITableView 配置部分
    • 当 UITableView 视图即将被展示在屏幕上时,会拉取所有行高数据
    • UITableView 在执行setLayoutMargins方法进行自身布局时会拉取所有行高数据
    • UITableView 在执行layoutSubviews方法进行子视图布局时会再次拉取所有行高数据
  • UITableViewCell 配置部分
    • 当使用 CellID 获取与 UITableView 绑定的 cell 时会拉取本行 cell 的高度数据
    • 当 cell 调用 layoutSubviews 方法急性布局时会再次拉取本行 cell 的高度数据

在上面列举的 5 种拉取 cell 高度数据的场景中,UITableView 配置部分只会在 UITableView 第一次展现在屏幕上时出现,但是它拉取的是所有行的行高数据,如果表视图有 100 行或者更多,那么这就是一个非常耗能的过程。

UITableViewCell 的配置部分,只有当 cell 将要出现在屏幕上时才会出现,并且只拉取当前 cell 的行高,这两种场景会在用户滑动 UITableView 时不断被执行,并且根据 UITableView 的 cell 布局原理,系统会默认准备比当前一屏高度所能容纳cell 的个数多 1 个 cell。

当执行reloadData方法进行界面刷新时,系统先会把所有行的行高数据拉取一遍,之后和 UITableViewCell 配置部分的场景一致,会拉取即将出现在屏幕上的 cell 的行高数据。下面是UITableView 的加载原理示意图:

iShot_2022-09-29_18.16.48.png

通过以上分析,以 10 行数据的视图为例,若一屏幕可以呈现 7 行数据(UITableView 需要准备 8 行),则在第一次展示 UITableView 视图时,会执行 44 次heightForRowAtIndexPath ,每次刷新 UITableView 需要执行 24 次heightForRowAtIndexPath ,如果 UITableView 行数增加的三位数,这个方法的执行次数将会非常惊人。

可变行高的优化方式

如果将复杂的计算代码写在heightForRowAtIndexPath 中,代价是巨大的。滑动不流畅、屏幕卡顿等很多性能问题都是由于这个原因。对于行高固定的表格视图,可以直接设置 UITableView 的固定行高,如果行高是不固定的,则应该想办法让heightForRowAtIndexPath 方法完成最少的工作。

其实最少的工作莫过于拿一个高度直接返回,因此通常会将对应行的行高计算一次后,把值保存起来,之后在执行heightForRowAtIndexPath 拉取行高时,直接返回。具体操作比较灵活,可以对应一个数组属性,将计算后的行高放入数组,在每次取行高时,检查数组中是否有已经计算过的行高数据,如果有直接返回。一种更好的方式是将行高数据封装进 cell 的数据模型 Model 中。

然而,这只是提高了代码性能,工作量和复杂度有增无减。iOS 7 之后,可以使用estimateRowHeight属性,iOS 11 中,系统已经默认定义这个值为 44 来进行列表视图的性能优化。这个值设置 cell 的大约行高。设置estimateRowHeight 无需再设置rowHeight,也不需要实现heightForRowAtIndexPath ,系统会根据 cell 中的 contentView 的约束来计算自己的行高。estimateRowHeight 用于 UITableView的初始化,会影响到表格视图右侧滚动条的宽度。当 cell 展现出来时,真正的行高并不受这个属性值的影响。

So,问题来了:如何让cell 正确计算自己的高度? 答案是使用 AutoLayout,给 cell 布局足够的压力,让 contentView 的上下左右必须被内部控件的约束撑满。

Note:cell 的子视图必须添加到 contentView 上,否则计算时会出现问题

这是性能最优的列表渲染方式。

上面说预估行高会影响到 UITableView 右侧滚动条的展示,如果每个 cell 行高跳跃跨度比较大,则滚动条宽度的配置会失准,随着用户滑动,右侧滚动条可能会出现长短跳跃的情况,如果想要精准这个滚动条的配置,可以在如下代理方法中返回具体 cell 的估计行高:

- (CGFloat)tableView:(UITableView *)tableView estimatedHeightForRowAtIndexPath:(NSIndexPath *)indexPath {
//这里根据不同分区或者不同行设置估计的行高
return 44;
}

关于estimatedHeightForRowAtIndexPath 这个方法还有一种应用场景: 对于没有使用自动布局、cell 的高度需要手动计算的场景,如果实现了这个方法,并且实现了heightForRowAtIndexPath方法,那么heightForRowAtIndexPath方法会以懒加载的方法执行,只有在 cell 将要被展现在屏幕上时才会被执行,这也可以有效减少由于高度计算带来的性能负担。

Note: UITableViewCell在被创建出来时,宽度并不一定和 UITableView 的宽度一致,如果需要获取 cell 的绝对宽度来处理逻辑,那么需要在 cell的 layoutSubviews 方法里面进行,此时 cell 的宽度才正确

高度不固定的列表分区头、尾视图

一般头尾高度固定,不考虑它们带来的性能问题。对比 cell 的布局原理,也可以使用自动布局实现自适应高度。

参考

《iOS 性能优化实战》

通过 Xcode 启动终端

使用过其他 IDE 的同学应该知道,大多数都集成了终端,而 Xcode 却没有。当我们要对一个项目执行命令行时,总要将项目拖到终端窗口中,这样很不方便。那如何使用 Xcode 一键启动终端并 cd 到当前项目目录呢?这篇文章就来介绍一种方案。

新建脚本文件:

Image.png 编辑脚本文件:

#!/usr/bin/env bash 
open -a iTerm "`pwd`"

脚本文件默认没有执行权限,启动终端,使用命令行

chmod +x <脚本路径>

赋予脚本权限。

在 Xcode → Preferences → Behaviors 中添加自定义 Open Terminal 选项,设置脚本路径及惯用快捷键

Image (2).png

完成之后就可以在 Xcode中通过快捷键一键调起终端并 cd 到项目目录。

配置起来很简单,使用起来很划算哦😏

iOS 线程保活

开发中,经常会遇到将耗时操作放到子线程中执行,来提升应用性能的场景。当子线程中的任务执行完毕后,线程就被立刻销毁。

如果开发中需要经常在子线程中执行任务,那么频繁的创建和销毁线程就会造成资源的浪费,这不符合我们的初衷。 此时就需要我们对线程进行保活,保证线程在应该处理事情的时候醒来,空闲的时候休眠。

我们知道 RunLoop 可以在需要处理事务的时候醒来执行任务,空闲的时候休眠来节省资源,利用这个特性就可以来处理线程的保活,控制线程的生命周期。

从探索到成功

- (void)viewDidLoad {
    [super viewDidLoad];
    
    LSThread *thread = [[LSThread alloc] initWithTarget:self selector:@selector(run) object:nil];
    [thread start];
}

- (void)run {
    NSLog(@"func -- %s   thread -- %@", __func__, [NSThread currentThread]);
    [[NSRunLoop currentRunLoop] run];
    NSLog(@"--- 结束 ---");
}

LSThread 继承自 NSThread ,重写了 dealloc 方法

- (void)dealloc {
    NSLog(@"%s", __func__);
}

执行之后的结果:

保活失败.png

可以看到线程没能保活:

  • 虽然启动了 RunLoop,依然执行了下面的结束 log
  • 线程在执行完毕之后被销毁了

为了保证线程执行完毕不被销毁,可以强引用线程

self.thread = [[LSThread alloc] initWithTarget:self selector:@selector(run) object:nil];
[self.thread start];

但是这样并不能解决 RunLoop 问题。那么已经启动了 RunLoop,为什么并没有保持它的持续运行呢?

我们来看一下 run 方法的定义

If no input sources or timers are attached to the run loop, this method exits immediately.

意思是如果没有sources或timers附加到RunLoop,那么这个方法会立即退出。

那么我们给 RunLoop 添加一个 source 或者 timer 应该就可以解决这个问题了

[[NSRunLoop currentRunLoop] addPort:[[NSPort alloc] init] forMode:NSDefaultRunLoopMode];

再次运行并没有执行结束 log,线程保活成功。

保活成功.png

下面继续来完善我们的需求。当持有线程的控制器销毁时,新建的子线程也应该跟着被销毁,在控制器里添加 dealloc

- (void)dealloc {
    NSLog(@"--- 销毁控制器 --- %s", __func__);
}

在控制器出现时,创建子线程,控制器消失时控制台输出如下

循环引用.png

控制器和子线程都没有被销毁。查看代码

self.thread = [[LSThread alloc] initWithTarget:self selector:@selector(run) object:nil];

这里控制器强引用了 thread,thread 又在内部持有了控制器 self,造成了引用循环。

那么要打破这个引用循环可以使用 Block

self.thread = [[LSThread alloc] initWithBlock:^{
        NSLog(@"func -- %s   thread -- %@", __func__, [NSThread currentThread]);
        [[NSRunLoop currentRunLoop] addPort:[[NSPort alloc] init] forMode:NSDefaultRunLoopMode];
        [[NSRunLoop currentRunLoop] run];
        NSLog(@"--- 结束 ---");
    }];

执行结果

解决循环引用.png

控制器被成功释放,但是子线程并没有被销毁,那么这个子线程变成了一个全局性质的。到这里就要说一下 RunLoop 的启动了。

RunLoop 有三种启动方式

- (void)run;

- (void)runUntilDate:(NSDate *)limitDate;

- (void)runMode:(NSString *)mode beforeDate:(NSDate *)limitDate;

run 方法内部会在NSDefaultRunLoopMode模式下重复调用runMode:beforeDate:方法。

runUntilDate: 方法可以设置超时时间,在超时时间到达之前,RunLoop会一直运行,在此期间RunLoop会处理来自sources的数据,并且 像 run 一样,也会在NSDefaultRunLoopMode模式下重复调用runMode:beforeDate:方法。

runMode:beforeDate: 方法RunLoop会运行一次,超时时间到达或者第一个source被处理,则RunLoop就会退出。

关于 run 方法 Apple 文档中有说如果希望退出 RunLoop,不应使用此方法。

如果RunLoop没有input sources或者附加的timer,RunLoop就会退出。虽然这样可以将RunLoop退出,但是Apple不建议我们这么做,系统内部有可能会在当前线程的RunLoop中添加一些输入源,所以通过手动移除input source或者timer这种方式,并不能保证RunLoop一定会退出。

那么问题就很明了了,我们不应该使用 run 方法来启动 RunLoop,因为它创建的是一个不会退出的循环,使用这个方法的子线程自然无法被销毁。我们可以像run 一样利用runMode:beforeDate: 方法来创建一个符合我们条件的子线程:

[[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];

把它放到一个 while 循环中,利用一个是否停止 RunLoop 的全局标记来辅助处理线程的生命周期问题

__weak typeof(self) weakSelf = self;
    self.thread = [[LSThread alloc] initWithBlock:^{
        NSLog(@"func -- %s   thread -- %@", __func__, [NSThread currentThread]);
        [[NSRunLoop currentRunLoop] addPort:[[NSPort alloc] init] forMode:NSDefaultRunLoopMode];
//        [[NSRunLoop currentRunLoop] run];
        while (!weakSelf.isStopedThread) {
            [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
        }
        NSLog(@"--- 结束 ---");
    }];

停止 RunLoop 的方法

- (void)stop {
    self.isStopedThread = YES;
    CFRunLoopStop(CFRunLoopGetCurrent());
}

这里有一点需要注意,停止操作一定要在我们的目标线程执行,比如我们直接调用 stop 方法并不能达到我们预期的效果,这是因为stop 默认在主线程执行,没有拿到目标线程,停止无效。

- (void)stopAction {
    [self performSelector:@selector(stop) onThread:self.thread withObject:nil waitUntilDone:YES];
    self.thread = nil;
}

在当前线程调用stop ,我们的目的就达到了,顺利的结束了 RunLoop,线程也跟着销毁了。

完成保活.png

Flutter 生命周期

如果曾对 iOS 中的 ViewController 有过接触,那就很容易理解生命周期在 UI 绘制中的重要作用。Flutter 中也存在生命周期,它的回调方法都体现在 State 中,源码参考

Flutter 的生命周期分为页面(Widget)和 APP 两块。理解Flutter生命周期, 对写出一个合理的 Widget 和一个健壮的 APP 至关重要。

页面的生命周期

以 StatefulWidget 为例,来看一下 Flutter 页面的生命周期是怎样的。 Widget 的生命周期大体上可以分为三个阶段:

1. 初始化

  • createState
     //这个方法是必须重写的      
     @override
     _LifecycleWidgetState createState() => _LifecycleWidgetState();

当构建一个 StatefulWidget 时这个方法会被首先调用,而且这个方法是必须要重写的。

  • initState
@override
  void initState() {
  super.initState();
}

这个方法调用发生在 createState之后,是除构造方法之外,调用的第一个方法,它的作用类似于 Android 的 onCreate()和 iOS 的 viewDidLoad()。这个方法中通常会做一些初始化工作,比如 channel 的初始化、监听器的初始化等。 与 dispose() 相对应。

2. 状态改变

  • didChangeDependencies

    @override
      void didChangeDependencies() {
        super.didChangeDependencies();
      }
    

    这个方法要求必须要调用父类的方法super.didChangeDependencies,当依赖的 State 的对象改变时会调用。

    1. 在第一次构建 Widget 时,在 initState()之后立即调用此方法。
    2. 如果 StatefulWidgets 依赖于 InhertedWidget,那么当当前 State 所依赖 InheritedWidget 中的变量改变时会再次调用它。
  • build

@override
  Widget build(BuildContext context) {
      return Container();
  }

是一个必须实现的方法,在这里实现要呈现的页面内容。它会在didChangeDependencies()之后立即调用,另外当调用 setState() 后也会再次调用这个方法

  • didUpdateWidget
@override
void didUpdateWidget(covariant LifecycleWidget oldWidget) {
     super.didUpdateWidget(oldWidget);
}

调用 setState 将 Widget 的状态改变时 didUpdateWidget 会被调用,Flutter 会创建一个新的 Widget 来绑定这个 State,并在这个方法中传递旧的 Widget ,因此如果想比对新旧 Widget 并且对 State 做一些调整,可以使用它。

另外如果某些 Widget 上涉及到 controller 的变更,那么一定要在这个回调方法中移除旧的 controller 并创建新的 controller 监听。

3. 销毁

  • deactivate

    @override
      void deactivate() {
        super.deactivate();
      }
    

    这个方法不常用,它会在组件被移除时调用,而且是在dispose 调用之前

  • dispose

    @override
      void dispose() {
        super.dispose();
      }
    

    与 initState() 对应。

    组件销毁时调用,通常该方法中执行一些释放资源的工作,如监听器的移除,channel 的销毁等,相当于 iOS 的 dealloc方法参考

App 的生命周期

App 中会有比如从前台切入到后台再从后台切回到前台的场景,在 iOS 中这些生命周期都可以在 AppDelegate 中被体现,那么 Flutter 中我们该如何处理这些场景?对于 App 级别的生命周期与上述 Widget 生命周期相比,稍有不同。

源码参考

如果想监听 App 的生命周期需要使用 WidgetsBinding 来监听 WidgetsBindingObserverWidgetsBindingObserver是一个 Widgets 绑定观察器,通过它来监听应用的生命周期,使用混入的方式绑定观察器,并且需要在 dispose 回调方法中移除这个监听。

重写 didChangeAppLifecycleState ,当生命周期发生变化的时候会回调这个方法,

class _LifecycleAPPState extends State<LifecycleAPP>
    with WidgetsBindingObserver {
@override
  void initState() {
    //添加监听
    WidgetsBinding.instance!.addObserver(this);
    super.initState();
  }

  @override
  Widget build(BuildContext context) {
    return Container();
  }

  @override
  void didChangeAppLifecycleState(AppLifecycleState state) {
    super.didChangeAppLifecycleState(state);
print(state);
  }

  @override
  void dispose() {
// 移除监听
    WidgetsBinding.instance!.removeObserver(this);
    super.dispose();
  }
}

Flutter 封装了一个枚举 AppLifecycleState 来描述 APP 的生命周期:

enum AppLifecycleState {
  resumed, // 进入前台
  inactive, // app 处于非活跃状态,并且未接收到用户输入的时候调用。比如接听来电
  paused,// 进入后台
  detached, // app 仍寄存在Flutter引擎上,但与原生平台分离
}

我们可以拿到这个 state 在 didChangeAppLifecycleState()来做一些我们需要的处理逻辑。

❌