怎么在百度上发布广告,深圳seo网络优化公司,宁波seo快速优化课程,长沙建站做企业网站公司我们核心类主要有四个#xff1a;
交换机、队列、绑定、消息。这四个核心类还可以继续向下划分。除了这几个还有其他的核心类#xff0c;先介绍这些#xff0c;等后面讲到了相关功能实现后面再补充。
核心类
Exchange
关于交换机#xff0c;我们主要需要实现三种交换机…我们核心类主要有四个
交换机、队列、绑定、消息。这四个核心类还可以继续向下划分。除了这几个还有其他的核心类先介绍这些等后面讲到了相关功能实现后面再补充。
核心类
Exchange
关于交换机我们主要需要实现三种交换机还有其他一些属性包括id、是否持久化、自动删除、参数思维导图如下图代码就不演示出来了具体的代码在末尾我会将马云地址贴出来代码中也有注释 此外方法中还包括了 getting、setting。
关于上述交换机
我这里单独设置了一个ExchangeType 利用枚举分别表示不同的交换机。这段代码很简单
public enum ExchangeType {DIRECT(0),FANOUT(1),TOPIC(2);private final int type;private ExchangeType(int type) {this.type type;}public int getType() {return type;}
}MSGQueue
这里先把几个基础的属性了解清楚其余的等到后面具体实现相关功能再来详细介绍。
先了解清楚如下几个属性name、durable、autoDelete、exclusive、arguments。
思维导图如下 Binding
绑定主要是用来连接交换机和队列的。Binding 这个东西是依附于 Exchange 和 Queue 的对于持久化来说如果 Exchange 和 Queue 任何一个都没有持久化此时你针对 Binding 持久化时没有意义的
Binding 其实很简单只有三个参数交换机的名字、队列的名字、绑定的 Key方法也是只有 对应的 setting、getting 加上 toString 方法
思维导图如下 Message
关于消息相比于上述的较为复杂它是由生产者通过网络传输到 BrokerServer 再由 BrokerServer 推送给消费者中途需要对消息进行序列化和反序列化操作等等。
属性这里来一个一个介绍
首先我们来进行一个约定约定好消息是怎么组成的。
我们这里约定我们的消息分为两个部分第一个部分是 BasicProperties
另一个部分就是消息本体 body 用于存储具体的消息、offsetBeg 、 offsetEnd这两个属性作为两个偏移量来找到某个具体的消息并且这两个属性不参与序列化和反序列化需要用 transient 修饰、isValidbyte类型用于判断消息是否有效0为有效1为无效
为什么 isValid 这里不采用 布尔类型来表示消息是否有效呢
主要原因
这些消息是存在文件中在文件中 boolean 是 四个字节 呢还是 一个字节呢这个说不准我也不知道这里就存在歧义为了不让歧义产生这里就选用了 byte 类型。 byte 类型只占一个字节占用空间较小
BasicProperties
BasicProperties 单独写一个类 这个BasicProperties 表示消息具体有哪些属性消息 IdroutingKey这属性是根据交换机类型来确定的是直接交换机这就表示为队列名、是扇出交换机这个就无意义、是主题交换机就需要相互匹配、deliverMode这表示消息是否需要持久化这个持久化和上述持久化是不一样的这个是保存在文件中 思维导图如下 核心类代码
数据库操作
数据库选用
我这里并没有采用到 MySQL数据库而是选用了 SQLlite 数据库原因如下
SQLite 是一种更加更轻量的数据库只有单独的一个可执行文件我们这里并没有实现跨平台客户端和服务器都是在本机上进行操作的采用SQLite更便捷SQLite 的配置更为简单不需要连接用户名和密码SQLite 不需要下载只需要在 pom.xml 引入就好
建表操作流程
1. 直接在 pom.xml 文件引入 SQLite库 依赖
!-- https://mvnrepository.com/artifact/org.xerial/sqlite-jdbc --dependencygroupIdorg.xerial/groupIdartifactIdsqlite-jdbc/artifactIdversion3.41.0.1/version/dependency
我用的就是上述版本
2. 在 appliaction.yml 配置文件中配置 库信息
spring:datasource:url: jdbc:sqlite:./data/meta.dbusername:password:driver-class-name: org.sqlite.JDBC
上述依赖和配置处理好后只要程序启动那么就会自动进行建库操作接下来就只需要进行建表操作即可。
存放在数据库中的只有三个交换机、队列、绑定那么我们只需要建这三种表即可。
3. 配置 MyBatis 文件
mybatis:mapper-locations: classpath:mapper/**Mapper.xml
MyBatis 的配置信息已经提到了这个路径所以需要去这个路径底下创建一个 interface
4. 创建一个 interface 5. 创建 mapper⽬录和⽂件 MetaMapper.xml 关于交换机的库操作
关于交换机库操作只有这三种添加交换机、查询所有交换机、删除交换机分别对应各自的sql 语句。
1. 实现接口方法
同样我们需要先在 mapper 包下写接口方法
void insertExchange(Exchange exchange);
ListExchange selectAllExchanges();
void deleteExchange(String exchangeName);
2. 在 xml 文件下实现 sql 语句 关于队列的库操作
关于队列库操作也只有这三种添加队列、查询所有队列、删除队列分别对应各自的sql 语句和交换机一样
1. 实现接口方法 void insertQueue(MSGQueue queue);ListMSGQueue selectAllQueues();void deleteQueue(String queueName);
2. 在 xml 文件下实现 sql 语句 关于绑定的库操作
关于绑定库操作也只有这三种添加绑定、查询所有绑定、删除绑定分别对应各自的sql 语句和交换机一样
1. 实现接口方法
void insertBinding(Binding binding);
ListBinding selectAllBindings();
void deleteBinding(Binding binding);
2. 在 xml 文件下实现 sql 语句 库操作及配置信息
