- 博客(48)
- 收藏
- 关注
RSS订阅原创 Vue全家桶实战-- 目录结构
Vue全家桶实战-- 目录结构pages图片位置较大放在public较小放在assets组件路由接口文件夹公共文件数据存储工具箱vuex路由文件
2020-11-24 07:05:58
265
原创 Vue全家桶实战-- 前端跨域解决方案
Vue全家桶实战-- 前端跨域解决方案跨域解决方案CORS跨域Easy Mock后端接口安装axios导入插件发送请求注意http和https允许将cookie跨域传输JSONP跨域安装插件导入插件发送请求测试与axios对比_jp0函数注意jsonp请求不是真正请求。xhr里面没有这个请求只在JS里面，在JS里面找语法url+option{参数}+回调函数，option没有可以省略掉接口代理跨域更受欢迎创建v
2020-11-24 05:32:02
245
原创 Vue全家桶实战-- Vue Cli4.0安装和使用
Vue Cli4.0安装和使用npm install -g @vue/cli启动项目cd malldemonpm run serve创建项目命令行创建的项目才能导进来运行依赖可视化项目端口
2020-11-24 04:50:08
166
原创 Linux常用指令--1
查找特定的文件find / -name " " 全局搜索find ~ -name "" 全局模糊查找find ~ -iname "" 全局模糊查找,不区分大小写查看find指令man find检索文件grep自己输入haha管道操作符筛选日志双重过滤过滤查找这个进程对文件内容做统计逐行按照空格切分出来指定行数NR(也就是筛选出表头)按照分隔符批量替换文件内容sed 's/Str/String/' repla
2020-10-27 06:52:56
78
原创 RocketMQ--springboot+dubbo实战整合
RocketMQ–springboot+dubbo实战整合验证节点是否在zookeeper中
2020-10-27 05:56:15
442
原创 RocketMQ--Zookeeper集群环境搭建
RocketMQ–Zookeeper集群环境搭建Zookeeper基础知识、体系结构、数据模型 1 zookeeper是一个类似linux、hdfs的树形文件结构，zookeeper可以用来保证数据在(zk)集群之间的数据的事务性一致、 2 zookeeper有watch事件，是一次性触发的，当watch监视的数据发生变化时，通知设置了该watch的client，即watcher 3 zookeeper有三个角色：Leader，Follower，Observer 4 zookeeper应用场景：
2020-10-25 15:07:58
795
原创 RocketMQ--抗压需求分析及解决方案
RocketMQ–抗压需求分析及解决方案大纲双十一抗压分析用户加入购物车用户下单用户支付双十一抗压解决方案总结
2020-10-25 10:35:57
96
原创 RocketMQ--双主双从部署实战
RocketMQ–双主双从部署实战两台机器部署master.两台机器部署slave,每台上面都有nameserver,从nameserver上注册,获取broker四个节点不允许自动创建topic控制台小结
2020-10-25 10:05:58
193
原创 RocketMQ--核心原理解析
RocketMQ–核心原理解析消息存储结构Commit Log 是物理存储的数据Commit Queue是消息逻辑的队列consumer采用zero copy零拷贝同步刷盘与异步刷盘同步复制与异步复制可以同步双写,异步复制去配置mq高可用机制NameServer协调服务最后一个hashmap已废弃小结...
2020-10-24 07:48:26
158
原创 RocketMQ--消费者PullConsumer使用
RocketMQ–消费者PullConsumer使用Producerpackage com.bfxy.rocketmq.consumer.pull;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.client.producer.DefaultMQProducer;import org.apache.rocketmq.client.producer.SendResu
2020-10-23 06:44:26
1560
原创 RocketMQ--PushConsumer长轮询模式分析
RocketMQ–PushConsumer长轮询模式分析PullRequestHoldService public void run() { log.info("{} service started", this.getServiceName()); while (!this.isStopped()) { try { if (this.brokerController.getBrokerConfig().isL
2020-10-23 06:32:14
279
原创 RocketMQ--消息存储核心-偏移量Offset
RocketMQ–消息存储核心-偏移量Offset集群模式broker存储广播模式consumer存储
2020-10-23 06:16:36
1014
原创 RocketMQ--PushConsumer消费模式-广播模式
RocketMQ–PushConsumer消费模式-广播模式广播模式可以解决集群模式不同消费端对不同Tag消息的对应消费MessageModel.BROADCASTINGconsumer.setMessageModel(MessageModel.BROADCASTING)会有冗余发送 String tags = msg.getTags(); if(tags.equals("TagB")) { System.out.println("收到消息：" + " topi
2020-10-23 06:07:04
399
原创 RocketMQ--PushConsumer消费模式-集群模式
RocketMQ–PushConsumer消费模式-集群模式=================================================================================================group_name要相同Listener发消息队列数要和consumer数量为倍数,才能负载均衡consumer现在不支持"|",建议一个Topic只有一个Tag=====================================
2020-10-23 05:47:22
683
原创 RocketMQ--消费者PushConsumer核心参数详解
RocketMQ–消费者核心讲解PushConsumer核心参数详解================================================================================================订阅注册MessageListenerConcurrently/** * A MessageListenerConcurrently object is used to receive asynchronously deli
2020-10-23 05:27:22
756
原创 RocketMQ--生产者自定义消息发送规则
RocketMQ–生产者自定义消息发送规则MessageQueueSelector SendResult sr = producer.send(message, new MessageQueueSelector() { @Override public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) { Integer queueNumber = (Intege
2020-10-22 06:54:21
256
原创 RocketMQ--生产者之延迟消息
RocketMQ–生产者之延迟消息MessageStoreConfig固定精度消息延迟时间 private String messageDelayLevel = "1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h";setDelayTimeLevel // 1. 创建消息 Message message = new Message("test_quick_topic", // 主题 "TagA", //
2020-10-22 06:46:18
216
原创 RocketMQ--生产者消息返回状态
SendStatuspackage org.apache.rocketmq.client.producer;public enum SendStatus { SEND_OK, //消息已经发送成功 //后面这三种情况,如果业务不允许丢消息,需要做相应的补偿,做可靠性的重投 FLUSH_DISK_TIMEOUT, //消息发送成功,但是服务器刷盘的时候超时了,消息已经进入服务器队列,只有服务器宕机,消息才会丢失 // 会等待下一次刷盘时机再去刷盘,如果服务器宕机,bro
2020-10-22 06:24:26
1075
原创 RocketMQ--Netty底层框架解析
框架实现接口RemotingClient==================================================================================================================================================================================================================RemotingSer
2020-10-22 06:08:16
374
原创 RocketMQ--生产者消息发送
异步发消息 // 2.2 异步发送消息// producer.send(message, new SendCallback() {// //rabbitmq急速入门的实战: 可靠性消息投递// @Override// public void onSuccess(SendResult sendResult) {// System.err.println("msgId: " + sendResult.getMsgId() + ", status: " + sendR
2020-10-21 06:55:25
418
1
原创 RocketMQ--主从同步机制解析
同步主从同步元数据信息的同步:topic config配置信息,consumer的offset(消费端的进度信息)等.不是即时同步,底层代码是启动定时任务去同步的消息数据的同步同步信息数据内容: commitlog实际消息的存储信息,是实时同步的元数据信息slave和master基于commitlog里面的数据不断对比数据丢失元数据丢失是可以接受的,可以恢复;如果元数据在slave和master里面不一致,可以做恢复,可以调整offset位置或者重启consumercommitlog里
2020-10-20 06:58:26
413
原创 RocketMQ--生产者核心讲解
内容核心参数producerGroup :组名在一个应用里面是唯一的createTopicKey: 实际生产中不会使此暴露,会再次封装defaultTopicQueueNums(默认为4):一个topic下默认挂的是四个队列sendMsgTimeout(单位:ms):消息发送的超时时间compressMsgBodyOverHowmuch(默认压缩字节4096):自动压缩机制,超过4096就会压缩retryTimesWhenSendFailed(可配置): 同步重发次数可以在配置文件里
2020-10-20 06:01:25
192
原创 RocketMQ--集群
集群环境不支持主从自动切换,但是可以使服务停止,写脚本使从节点变成主节点同步双写,异步复制都是对应双主双从主从模式集群环境构建与测试同步刷盘,投递一条消息后,关闭主节点,生产者拿到消息后反应的是消息投递失败异步刷盘,投递一条消息后,关闭主节点,生产者拿到消息后反应的是消息投递成功主节点上线,消息同步后,consumer在拉消息的时候,不在拉取这条已经被消费的消息,会做一个标记关闭先有的服务# cd /usr/local/rocketmq/bin# sh mqshutdown brok
2020-10-19 06:51:18
162
原创 Rocketmq--入门
主要内容生产者使用一个组只能有一个生产者主名称topic默认4个队列异常public class Const { public static final String NAMESRV_ADDR_SINGLE = "192.168.11.81:9876"; public static final String NAMESRV_ADDR_MASTER_SLAVE = "192.168.11.81:9876;192.168.11.82:9876";}public class Prod
2020-10-19 06:00:41
129
1
原创 Rocketmq--控制台使用
控制台使用修改配置文件修改namesrvAddr即可启动访问控制台介绍配置项namesrvAddr可以修改消息情况节点事务性消息包含重试机制,导致生产消费的数量不一致,不能以这边的数字为准Topic 订阅主题可以查看状态配置信息可以新建topic查看日志consumer 消费者-1不延迟结合定时任务复位消息producer消息生产者message可以消息查询总结...
2020-10-18 12:53:28
466
原创 RocketMQ--环境构建和启动
环境搭建修改hostsvim /etc/hosts上传编译好的包# 上传 apache-rocketmq.tar.gz 文件至/usr/local# tar -zxvf apache-rocketmq.tar.gz -C /usr/local# 建立软链接ln -s apache-rocketmq rocketmqll /usr/local=====================================================================
2020-10-18 12:28:29
247
1
原创 RocketMQ--源码编译和介绍
整体介绍概念模型RocketMQ源码包编译http://rocketmq.apache.org/eclipse修正编译编译成功包的位置源码结构!具体结构
2020-10-18 12:11:34
439
原创 tomcat运行前端源码api
tomcat运行前端源码静态服务器Tomcatspringboot内嵌的tomcat里面是9.0版本前端源码BO前后端对应 var userBO = { username: this.username, password: this.password, confirmPassword: this.confirmPassword };app.js /* 开发环境 */ // serverUrl: "htt
2020-10-12 07:05:42
198
原创 整合Swagger2文档api
引入依赖 <!-- swagger2 配置 --> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger2</artifactId> <version>2.4.0</version> </dependency> <dependency> <gro
2020-10-10 07:21:28
131
原创 用户登录注册
用户登录注册流程用户登录邮箱注册需要邮件服务器或者商业收费的邮箱手机注册用户表分布式时要保证主键id全局唯一,不能使用主键自增代码登录servicepublic boolean queryUsernameIsExist(String username) { Example userExample = new Example(Users.class); Example.Criteria userCriteria = userExample.
2020-10-10 06:44:46
377
原创 算法训练营--数组、链表、跳表
数组数组的底层结构数组删除元素ArrayListhttp://developer.classpath.org/doc/java/util/ArrayList-source.htmladd()ensureCapacity()如果minCapacity长度不够,新的数组的长度为当前的长度再乘以2,然后把旧数组的值拷贝到新数组里面,返回一个新数组 170: public void ensureCapacity(int minCapacity) 171: { 172:
2020-10-09 07:07:33
114
原创 详解事务的传播
详解事务的传播@Transactional(propagation = Propagation.SUPPORTS)事务种类(Propagation) /** * 事务传播 - Propagation * REQUIRED: 使用当前的事务，如果当前没有事务，则自己新建一个事务，子方法是必须运行在一个事务中的； * 如果当前存在事务，则加入这个事务，成为一个整体。 * 举例：领导没饭吃，我有钱
2020-10-08 16:09:29
685
1
原创 Restful webservice
Restful webserviceRest设计规范逆向mapper多次运行追加问题mapperscan这边用的是tk包的注解路径映射问题[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-DyJQqfQs-1602139009680)(http://blog.img.candidcrat.net.cn/image-20201008124852583.png?candid)]注入失败问题开发工具可以去掉,也可以更改等级幂等性问题后面补充
2020-10-08 14:37:34
92
原创 MyBatis 数据库逆向生成工具
MyBatis 数据库逆向生成工具介绍项目导入 <!-- 通用mapper逆向工具 --> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.1.5</version> </dependency>ym
2020-10-08 11:10:54
214
1
原创 HikariCP数据源
HikariCP数据源springboot2.0无需引入，已经默认引入该依赖application.yml数据源配置connection-test-query: SELECT 1 连接的时候测试的sql语句############################################################## 配置数据源信息#############################################################spring:
2020-10-08 10:37:12
305
1
原创 springboot自动装配
启动类@SpringBootApplicationpublic class Application { public static void main(String[] args) { SpringApplication.run(Application.class,args); }}run()看注释default settings和the running {@link ApplicationContext}SpringBootApplication.java
2020-10-08 10:10:27
89
原创 IDEA类与方法模板配置
类/** * @projectName ${PROJECT_NAME} * @title ${NAME} * @package ${PACKAGE_NAME} * @description ${TODO} * @author juzizhou * @date ${DATE} ${TIME} * @version V1.0.0 * @copyright ${YEAR} */方法按tab键** * @Descriptio
2020-10-06 16:03:08
101
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人