博文纲领：
内功修炼:Java多线程之消息队列
内功修炼：Java多线程之消息队列在库存管理中的应用 在Java多线程编程中，消息队列是一种重要的机制，用于实现线程间的通信与同步。以下是在电商库存管理场景中，消息队列的具体应用及其作用：确保库存实时更新：作用：消息队列确保了库存状态的实时更新。
pubsub和消息队列区别
Pub/Sub（发布/订阅）和消息队列是两种常见的消息传递模式，它们在应用程序之间进行异步通信时有着不同的特点和用途。
做消息队列：利用Redis的PubSub功能实现消息传递，简化消息队列实现。 生成全局ID：使用Redis的incrby命令生成全局ID，适用于分库分表场景的批量操作。在使用Redis时，需注意优化策略和可能出现的问题，以充分发挥其性能优势。
存在的问题有：发送者发送一条消息，若没有订阅者，则消息直接丢弃。若发送期间，一个订阅者断开连接，那么在断开连接期间消息对于该订阅者来说彻底丢失了。此外，redis停机重启，pubsub的消息是不会持久化的，所有的消息被直接丢弃。
非结构化数据如何可视化呈现？
1、按图像数据可视化：使用具有真实含义的图像和图标，使数据和图表更加逼真，易于理解。示例包括男性和女性图标的比例显示。 通过概念实现数据可视化：将抽象的指标数据转换为熟悉且易于理解的数据，以形象地解释概念。示例包括非结构化数据的解释和信息图。
2、信息可视化 信息可视化是一个跨学科领域，其核心在于利用视觉呈现手段来处理大规模的非数值型信息资源。这包括了软件系统中的文件、程序代码等复杂信息集合，以及抽象数据集如非结构化文本、高维空间中的点等。
3、强大的搜索引擎 Elasticsearch 与传统关系型数据库的一个明显不同点在于 前者是一个非结构化的 NoSQL数据库，因此里面的很多概念诸如索引、类型、文档等对于初学者可能会有些疑惑。
4、信息可视化（Information visualization）则是一个跨学科领域，主要研究大规模非数值信息资源的视觉呈现。信息可视化侧重于帮助人们理解和分析数据，特别是在处理软件系统中的大量非数值型信息时更为有效。例如，软件系统中的文件、程序代码等，以及非结构化文本或高维空间中的点等数据集。
消息队列原理及选型
如果Consumer宕机/关闭，没有发送ACK，消息队列将认为这个消息没有被处理，会将这个消息重新发送给其他的Consumer重新消费处理。 消息的收发处理支持事务，例如：在任务中心场景中，一次处理可能涉及多个消息的接收、处理，这应该处于同一个事务范围内，如果一个消息处理失败，事务回滚，消息重新回到队列中。
消息队列的工作原理主要是基于生产者-消费者模型，通过异步通信的方式来传递数据或任务。消息队列是一种通信方法，它允许独立的应用程序通过读写出入队列的消息来进行交互。在生产者-消费者模型中，生产者负责创建消息并将其发送到队列中，而消费者则从队列中获取并处理这些消息。
即ACK机制，当Consumer确认消息已经被消费处理，发送一个ACK给消息队列，此时消息队列便可以删除这个消息了。如果Consumer宕机/关闭，没有发送ACK，消息队列将认为这个消息没有被处理，会将这个消息重新发送给其他的Consumer重新消费处理。
定义：RocketMQ顺序消息是其重要特性之一，适用于有先后顺序要求的场景。适用场景：如订单处理、支付、发货等，这些场景中的操作必须严格遵循顺序，以确保数据的正确性和业务逻辑的一致性。实现原理 消息队列管理：RocketMQ通过消息队列来管理顺序消息。
消息队列核心原理
消息的收发处理支持事务，例如：在任务中心场景中，一次处理可能涉及多个消息的接收、处理，这应该处于同一个事务范围内，如果一个消息处理失败，事务回滚，消息重新回到队列中。
即ACK机制，当Consumer确认消息已经被消费处理，发送一个ACK给消息队列，此时消息队列便可以删除这个消息了。如果Consumer宕机/关闭，没有发送ACK，消息队列将认为这个消息没有被处理，会将这个消息重新发送给其他的Consumer重新消费处理。
在消息传递机制中，消息与队列是核心概念。消息是通信双方交换的信息载体，形式多样，如文本、声音、图像，传递方式与格式由双方商定，既起到数据加密作用，又能降低通信量。消息内含发送与接收者标识，确保信息定向传输，包含时间戳以支持时间相关应用处理，设置到期时间则在规定时间内未送达的信息将失效。