数据持久化方案解析（八） —— UIDocument的数据存储（一）

Posted 2023-04-16

参考技术A 首先看下框架基本信息

使用 UIDocument 及其底层架构的应用程序可为其文档带来许多好处：

在 Model-View-Controller 设计模式中， UIDocument 对象是模型对象或模型控制器对象 - 它管理文档的数据或共同构成文档数据的聚合模型对象。您通常将其与视图控制器配对，该视图控制器管理显示文档内容的视图。 UIDocument 不支持管理文档视图。

基于文档的应用程序包括可以生成多个文档的应用程序，每个文档都有自己的文件系统位置。基于文档的应用程序必须为其文档创建 UIDocument 的子类。有关详细信息，请参阅下面的 Subclassing Notes 。

UIDocument 体系结构中文档的主要属性是其文件URL。 通过调用 initWithFileURL: 初始化文档子类的实例时，必须传递在应用程序沙箱中查找文档文件的文件 URL 。 UIDocument 从文件URL确定文件类型（与文件扩展名关联的统一类型标识符）和文档名称（文件名组件）。 您可以覆盖 fileType 和 localizedName 属性的访问器方法以提供不同的值。

以下概述了典型 document 的生命周期（有关实现细节，请参阅 Subclassing Notes ）：

典型的基于文档的应用程序在主线程上调用 openWithCompletionHandler: ， closeWithCompletionHandler: 和 saveToURL:forSaveOperation:completionHandler: 。当这些方法启动的读取或保存操作结束时，完成处理程序块在调用该方法的同一调度队列上执行，允许您根据读取或保存操作完成任何任务。如果操作不成功，则将 NO 传递到完成 - 处理 (completion-hander) 程序块。

UIDocument 类采用 NSFilePresenter 协议。当另一个客户端尝试读取基于 UIDocument 的应用程序的文档时，该读取将暂停，直到 UIDocument 对象有机会保存对该文档所做的任何更改。

虽然有些实现什么都不做，但 UIDocument 实现了所有 NSFilePresenter 方法。具体来说， UIDocument ：

在您的 UIDocument 子类中，如果重写 NSFilePresenter 方法，则始终可以调用超类实现 （super） 。

每个基于文档的应用程序必须创建 UIDocument 的子类，其实例表示其文档。大多数应用程序的子类化要求很简单：

contentsForType：error： 和 loadFromContents：ofType：error： 通常在主队列上调用方法。进一步来说：

如果您对读取和写入 contentsForType：error： 和 loadFromContents：ofType：error： 方法的文档数据有特殊要求，则可以重写 UIDocument 类的其他方法。有关这些要求和方法的讨论，请参阅 Advanced Overrides 。

要启用 UIDocument 的自动保存功能，您必须在用户更改文档时通知它。 UIDocument 定期检查 hasUnsavedChanges 方法是否返回 YES ; 如果是，则启动文档的保存操作。

在 UIDocument 子类中实现更改跟踪有两种主要方法：

UIDocument 对象在其生命周期中的任何时刻都具有特定状态。您可以通过查询 documentState 属性来检查当前状态，并通过观察 UIDocumentStateChangedNotification 通知获得有关更改的通知。

如果为 iCloud 启用了文档，则检查是否存在冲突版本并尝试解决冲突非常重要。通过侦听 UIDocumentStateChangedNotification 通知然后检查文档状态是否为 UIDocumentStateInConflict 来执行此操作。此状态表示文档存在冲突版本，您可以通过调用 NSFileVersion 类方法 unresolvedConflictVersionsOfItemAtURL： 来访问该文档，并传入文档的文件URL。如果您无需用户交互即可正确解决冲突，请执行此操作。否则，离散地通知用户存在冲突并让他们选择如何解决冲突。可能的方法包括：

除了指示文件间冲突之外，文档状态可以指示错误。例如， UIDocumentStateClosed 表示读取时出错， UIDocumentStateSavingError 表示保存或还原文档时出错。通过传递给 openWithCompletionHandler： ， closeWithCompletionHandler： ， revertToContentsOfURL：completionHandler： 和 saveToURL：forSaveOperation：completionHandler： 方法的完成处理程序的 success 参数，通知您的应用程序读取和写入错误。

您可以通过调用或实现 handleError:userInteractionPermitted: 方法来处理错误；此方法由 openWithCompletionHandler 的默认实现调用和 saveToURL：forSaveOperation：completionHandler： 分别在 UIDocument 对象遇到读取或写入错误时的方法。您可以通过通知用户来处理读取，保存和还原错误，如果情况允许，则尝试从错误中恢复。

请务必阅读 contentsForType：error： 方法的说明，以获取有关处理文档保存期间遇到的错误的指导。

如果应用程序对读取或写入文档数据有特殊要求，它可以覆盖除 loadFromContents:ofType:error: 和 contentsForType:error: 之外的 UIDocument 方法。这些要求通常包括以下内容：

如果覆盖大多数这些方法，请注意所有文档数据的读取和写入必须在后台队列上完成，并且必须与其他尝试读取和写入同一文档文件相协调。因此，您通常应该将超类实现 （super） 作为覆盖的一部分来调用，如果调用其他 UIDocument 方法，则通常应该在传入 performAsynchronousFileAccessUsingBlock： 方法调用的块中调用它们。阅读方法描述以获取详细信息。

如果通过覆盖相关的访问器方法来覆盖任何文档属性属性（在 Accessing Document Attributes 下列出），请注意 UIKit 框架可以在后台线程上调用这些访问器方法。 因此，您的重写实现必须是线程安全的。

返回使用其文件系统位置初始化的文档对象。

JMS学习八（ActiveMQ的消息持久化到Mysql数据库）

1、将连接Mysql数据库的jar文件，放到ActiveMQ的lib目录下

      

2、修改ActiveMQ的conf目录下的active.xml文件，修改数据持久化的方式

       2.1  修改原来的kshadb的持久化数据的方式

<persistenceAdapter>  
        <!--  <kahaDB directory="${activemq.data}/kahadb"/> -->  
    <jdbcPersistenceAdapter  dataSource="#mysql-ds"/>  
 </persistenceAdapter>  

 

 

       2.2  连接Mysql的配置(注意配置文件放置的位置)

 

<!-- 用于持久化数据到Mysql数据库 -->  
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>  
        <property name="url" value="jdbc:mysql://localhost:3306/activemq?relaxAutoCommit=true"/>  
        <property name="username" value="root"/>  
        <property name="password" value="1234"/>  
        <property name="maxActive" value="200"/>  
        <property name="poolPreparedStatements" value="true"/>  
  
</bean> 

 

 

3、将数据持久化Mysql的运行截图

      3.1  重新启动ActiveMQ，并运行程序，放入持久化数据，查看Mysql的active数据库

 

4、放入持久化数据的代码

 

import javax.jms.Connection;  
import javax.jms.ConnectionFactory;  
import javax.jms.DeliveryMode;  
import javax.jms.Destination;  
import javax.jms.MessageProducer;  
import javax.jms.Session;  
import javax.jms.TextMessage;  
  
import org.apache.activemq.ActiveMQConnectionFactory;  
  
public class Sender {  
  
    public static void main(String[] args) throws Exception {  
  
        // 1、建立ConnectionFactory工厂对象，需要填入用户名，密码，以及连接的地址  
        // 仅使用默认。端口号为"tcp://localhost:61616"  
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(  
                "zhangsan",// ActiveMQConnectionFactory.DEFAULT_USER,  
                "123",// ActiveMQConnectionFactory.DEFAULT_PASSWORD,  
                "tcp://localhost:61616");  
        // 2、通过ConnectionFactory工厂对象创建一个Connection连接  
        // 并且调用Connection的start方法开启连接,Connection默认是不开启的  
        Connection connection = connectionFactory.createConnection();  
        connection.start();  
  
        // 3、通过Connection对象创建Session会话（上下文环境对象），  
        // 参数一，表示是否开启事务  
        // 参数二，表示的是签收模式，一般使用的有自动签收和客户端自己确认签收  
  
        // 第一个参数设置为true，表示开启事务  
        // 开启事务后，记得要手动提交事务  
  
        Session session = connection.createSession(Boolean.TRUE,  
                Session.CLIENT_ACKNOWLEDGE);  
  
        // 4、通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象。  
        // 在PTP模式中,Destination指的是Queue  
        // 在发布订阅模式中，Destination指的是Topic  
        Destination destination = session.createQueue("queue1");  
  
        // 5、使用Session来创建消息对象的生产者或者消费者  
        MessageProducer messageProducer = session.createProducer(destination);  
  
        // 6、如果是，生产者，使用MessageProducer的setDeliverMode方法设置，消息的持久化和非持久化  
        messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);  
        // 7、最后使用JMS规范的TextMessage形式创建数据(通过Session对象)  
        // 并利用MessageProducer的send方法发送数据  
        for (int i = 0; i < 5; i++) {  
            TextMessage textMessage = session.createTextMessage();  
            textMessage.setText("我是消息" + i);  
            messageProducer.send(textMessage);  
        }  
  
        // 手动提交开启的事务  
        session.commit();  
  
        // 释放连接  
        if (connection != null) {  
            connection.close();  
        }  
    }  
}