百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

商城微服务项目组件搭建(五)——Kafka、Tomcat等安装部署

myzbx 2025-03-25 15:39 54 浏览

1、本文属于mini商城系列文档的第0章,由于篇幅原因,这篇文章拆成了6部分,本文属于第5部分


2、mini商城项目详细文档及代码见CSDN:

https://blog.csdn.net/Eclipse_2019/article/details/132141211


3、本文主要讲解Kafka、Apache Druid、Sentinel、Tomcat的安装部署以及在ideal中启动vue项目的流程

2.16 Kafka安装

137服务器

关于Kafka安装,我们可以参考
http://kafka.apache.org/documentation/#quickstart

为了更方便安装Kafka,我们换种方式采用Docker容器安装,安装如下:

docker run -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.8.137:2181/kafka -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.8.137:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime --restart always wurstmeister/kafka

参数说明:

KAFKA_BROKER_ID:当前Kafka的唯一ID

KAFKA_ZOOKEEPER_CONNECT:当前Kafka使用的Zookeeper配置信息


KAFKA_ADVERTISED_LISTENERS:对外发布(暴露)的监听器,对外发布监听端口、地址

KAFKA_LISTENERS:监听器,告诉外部连接者要通过什么协议访问指定主机名和端口开放的 Kafka 服务。

注意,安装前务必先安装好Zookeeper,由于上一章我们已经安装了Zookeeper,所以这里不再演示Zookeeper安装流程。

安装好后,我们可以验证一下Kafka是否可用,验证kafka主要使用内部集成的命令实队列创建、现消息发送、消息消费。

2.16.1 创建队列

我们首先进入到kafka容器的 kafka_2.13-2.7.0/bin/ 目录下,该目录下有很多可执行的脚本,用于队列创建、发送消息、消费消息等,操作如下:

docker exec -it kafka /bin/bash

cd /opt/kafka_2.13-2.7.0/bin/

脚本如下:

创建队列mslogs:

./kafka-topics.sh --create --bootstrap-server 192.168.8.137:9092 --replication-factor 1 --partitions 1 --topic msitemslog

参数说明:

使用kafka-topics.sh创建队列

--create:执行创建一个新的队列操作

--bootstrap-server:需要链接的kafka配置,必填

--replication-factor 1:设置分区的副本数量

--topic mslogs:队列的名字叫mslogs

2.16.2 发送消息

在kafka容器中执行消息发送(接着上面的步骤执行):

./kafka-console-producer.sh --broker-list 192.168.8.137:9092 --topic mslogs

参数说明:

使用kafka-console-producer.sh实现向kafka的mslogs队列发送消息

--broker-list:指定将消息发给指定的Kafka服务的链接列表配置

--topic mslogs:指定要发送消息的队列名字

此时回车进入下面命令行操作界面:

我们可以发送这样的消息:

{"accesstime":"2020-12-10 16:30:30","uri":"/item/1.html","ip":"119.123.100.2"}

2.16.3 消息消费

我们执行脚本消费mslogs的数据,命令如下:

./kafka-console-consumer.sh --bootstrap-server 192.168.8.137:9092 --topic mslogs --from-beginning

参数说明:

使用kafka-console-consumer.sh从kafka中消费mslogs队列的数据

--bootstrap-server:从指定的kafka中读取消息

--topic mslogs:读取队列的名字

--from-beginning:从最开始的数据读取,也就是读取所有数据的意思

消费信息如下:

2.16.4 Lua操作Kafka

Lua操作Kafka主要实现MQ消息发送和MQ消息消费,我们项目中主要实现发送消息,此时我们需要写一个Lua库或者借助其他Lua库,写一个Lua库成本比较大,可以借助github上开源的lua库
https://github.com/doujiang24/lua-resty-kafka。

下载安装包:

在下发的资料/Kafka目录下已经下载好了该库文件lua-resty-kafka-master,将该库文件上传至/usr/local/openresty,并解压unzip
lua-resty-kafka-master.zip -d/usr/local/openresty

nginx要想使用到该lua库,需要在nginx.conf中配置当前lua库文件路径,在http中配置如下:

lua_package_path "/usr/local/openresty/lua-resty-kafka-master/lib/?.lua;;";

2.17 Apache Druid安装

137服务器

安装包下载地址:
http://druid.apache.org/downloads.html

资料/ApacheDruid目录下已经提供安装包

首先下载下来该安装包,并上传到服务器指定目录下/usr/local/eclipse2019,并解压改文件:

tar -xf apache-druid-0.22.0-bin.tar.gz

我们这里为了方便操作,启动单机版即可,但单机版启动会自动加载Zookeeper,集群版可以自由配置Zookeeper外部节点,但单机版不行。我们前面Kafka也用到了Zookeeper,为了让2个Zookeeper不冲突,我们需要将要安装的Apache Druid的Zookeeper端口换掉,把2181换成3181,在 apache-druid-0.20.0 目录下执行如下2行命令即可:

sed -i "s/2181/3181/g" `grep 2181 -rl ./`

sed -i "s/druid.zk.service.host=localhost/druid.zk.service.host=localhost:3181/g" `grep druid.zk.service.host=localhost -rl ./`

说明:sed -i "s/原字符串/新字符串/g" grep 原字符串 -rl 所在目录

Druid的时区和国内时区不一致,会比我们的少8个小时,我们需要修改配置文件,批量将时间+8,代码如下:

sed -i "s/Duser.timezone=UTC/Duser.timezone=UTC+8/g" `grep Duser.timezone=UTC -rl ./`

接下来进入到
/usr/local/eclipse2019/apache-druid-0.20.0/bin
目录下启动Apache Druid即可:

./start-micro-quickstart

启动后,等待20秒我们可以访问Apache Druid的控制台
http://192.168.8.137:8888/
效果如下:

注意:如果需要后台运行,可以直接执行nohup ./start-micro-quickstart &

如果ApacheDruid 跟Seata-server部署在同一台服务器则会出现8091端口冲突,只需要将
/usr/local/eclipse2019/apache-druid/conf/druid/single-server/micro-quickstart/middleManager/runtime.properties文件中的druid.plaintextPort=8091改成8891,同时,还有修改
/usr/local/eclipse2019/apache-druid/bin目录下的verify-default-ports中的8091为8891。

注意,如果centos7中没有安装jdk的话,则需要先安转

1、查看系统的位数:

getconf LONG_BIT

2、下载jdk

Oracle官网下载地址:
https://www.oracle.com/java/technologies/javase/javase-jdk8-downloads.html

3、解压:

切换目录到 cd /usr/local/eclipse2019

创建目录 mkdir jvm

使用Xshell和Xftp将安装包传输到虚拟机的
/usr/local/eclipse2019/jvm目录下

切换到
/usr/local/eclipse2019/jvm目录下 cd
/usr/local/eclipse2019/jvm

tar -zxvf jdk-8u271-linux-x64.tar.gz

改名:mv jdk1.8.0_271/ java

删除压缩包:rm -f
jdk-8u212-linux-x64.tar.gz

4、编辑环境变量文件:vim /etc/profile

将下面的内容粘贴到文件末尾:

JAVA_HOME=/usr/local/eclipse2019/java

JRE_HOME=/usr/local/eclipse2019/java/jre

CLASSPATH=.:$JAVA_HOME/lib:/dt.jar:$JAVA_HOME/lib/tools.jar

PATH=$PATH:$JAVA_HOME/bin

使配置生效:source /etc/profile

5、查看是否成功:java -version

2.18 Sentinel控制台安装

137或139服务器

docker run --name sentinel -d -p 8858:8858 -d bladex/sentinel-dashboard

安装好了后,我们可以直接访问http://192.168.8.137:8858访问控制台,默认用户名和密码都是 sentinel

2.19 Tomcat安装

1、拉去镜像文件

docker pull tomcat

2、启动tomcat

docker run -d -p 8080:8080 tomcat

3、访问http://ip:8080/

4、如果访问报404的错误,是因为版本太高,访问的资源再webapps.dist里面

  • 首先进入到tomcat容器中

docker exec -it 容器id /bin/bash

  • 删除webapps文件

rm -rf webapps

  • 重命名

mv webapps.dist webapps

5、再访问就成功了

上传文件到服务器

1、rz 命令上传zip文件到服务器

2、把文件放到tomcat容器下的webapps文件夹下

docker cp /root/vueshop.zip de807e6bf422:/usr/local/tomcat/webapps

3、解压文件夹

unzip vueshop.zip

4、删除压缩包

rm -f vueshop.zip

2.20 ideal启动vue项目

用idea打开vue项目 有以下几个步骤 1)给idea安装vue的插件 2)给vue项目安装依赖 3)添加自启动便捷方式

1)给idea安装vue的插件(已有vue插件的,可跳过此步骤) file–>settings–>plugins

2)给vue项目安装依赖 点击idea,下方的Terminal,输入npm install,给项目安装依赖

3)添加自启动便捷方式 点击小锤子旁边的Edit Configurations,会弹出一个弹窗

配置选项,package.json选择的是项目自带的package.json,Scipts点击右侧下拉,选中命令,一般启动是dev或start等等,这个一般来源于项目自带的package.json设置的启动命令。build一般是打包项目的。设置完毕点击apply–>ok

这样就能看到小锤子旁边有运行的了,点击运行就行了。

在重新build一下node-sass就可以了,输入指令:npm rebuild node-sass即可。

相关推荐

别再问Cookie了,再问就崩溃了!_别问 再问

作者:懿来自:Java极客技术说实话,之前面试都是直接去背诵的面试题,关于Cookie的一些内容,比如说,记录浏览器端的数据信息啦,Cookie的生命周期啦,这些内容,也从来没有研究过C...

5分钟学会物流轨迹地图API嵌入到页面中,实现物流轨迹可视化

前言在电子商务和在线购物日益普及的今天,为用户提供实时的物流信息已成为提升客户满意度的关键。本文将指导您如何在网页中嵌入物流轨迹地图API,以便用户能够直观地跟踪他们的包裹。1.申请接口、获取API密...

Springboot项目中几种跨域的解决方法

环境:springboot2.3.9.RELEASE什么是跨源资源共享跨源资源共享(CORS)(或通俗地译为跨域资源共享)是一种基于HTTP头的机制,该机制通过允许服务器标示除了它自己以外的其它...

基于Java实现,支持在线发布API接口读取数据库,有哪些工具?

基于java实现,不需要编辑就能发布api接口的,有哪些工具、平台?还能一键发布、快速授权和开放提供给第三方请求调用接口的解决方案。架构方案设计:以下是一些基于Java实现的无需编辑或只需少量编辑...

Axios VS Fetch, 用哪个更好?详细对比附案例

在JavaScript中进行HTTP请求时,最常用的两个工具是:原生fetchAPI流行的第三方库Axios我都在生产环境中使用过这两个工具。虽然两者都表现良好,但有时我会后悔选择了其中一个而非另一...

Ollama:Web搜索API和MCP_oalib search

如果您曾经尝试过LLM,您就会明白其中的痛点:模型在模式匹配方面非常出色,但往往会虚构一些东西。如果你问起上周发生的事情,突然间,您得到的只是来自2022年的鬼故事。这次更新改变了这一切。基本上...

基于浏览器扩展 API Mock 工具开发探索|得物技术

一、前言在日常开发过程中,偶尔会遇到后端接口未完成或者某个环境出现问题需要根据接口返回来复现等等场景。刚好最近在学习浏览器插件的相关知识,并在此背景下开发了一款基于浏览器插件的Mock工具。该工...

JavaScript动态注入的几种方法_js动态引入js

在现代的Web开发中,JavaScript动态注入是一个强大的技术,它允许开发者在网页运行时动态地修改网页内容和行为,方便进行调试和维护。动态注入通常涉及以下几个关键概念:DOM(文档对象模型)、和...

面试官:如何通过 MyBatis 查询千万数据并保证内存不溢出?

推荐学习真香警告!Alibaba珍藏版mybatis手写文档,刷起来牛掰!“基础-中级-高级”Java程序员面试集结,看完献出我的膝盖闭关28天,奉上[Java一线大厂高岗面试题解析合集],备战金九银...

nextjs教程三:获取数据_nextcloud数据迁移

数据的获取数据获取是任何应用程序中最重要的部分,本文将介绍,如何在react,nextjs中获取数据主要有种方法可以获取数据在服务端,用fetch获取数据在客户端,通过路由处理器获取数据下面分别...

Fetch API 教程_fetch_all

JavaScript初学者学完语法,进入实际的网页编程,一定有人告诉你,要掌握一个叫做XMLHttpRequest的东西。脚本都靠它发出HTTP请求,跟服务器通信。所谓的AJAX操作就是...

Mozilla火狐39.0正式版增加Emoji支持

2015-07-0310:41:43作者:李熙Mozilla旗下浏览器火狐(Firefox)39.0正式版在今日发布,新版在性能上改进不大,着重于浏览器的功能和细节改进:新版提升了Firefox...

如何设计前端监控sdk,实现前端项目全链路监控

一、埋点系统设计与实现(文章最后有如何回答)1.埋点分类1.1手动埋点(代码埋点)//业务代码中主动调用tracker.track('button_click',{&nbs...

如何快速实现一套流程编排系统,前端开发组件都有哪些,一篇搞懂

早上9点,AI产品经理紧急拉会:“我们的客户明天要看到AI审批流程原型,传统开发至少要一周,有什么办法今天就能上线?”这时,你打开流程编排画布,拖拽几个节点,连接大模型API和服务,1小时后客户竖起...

2023金九银十必看前端面试题!2w字精品!

导文2023金九银十必看前端面试题!金九银十黄金期来了想要跳槽的小伙伴快来看啊CSS1.请解释CSS的盒模型是什么,并描述其组成部分。答案:CSS的盒模型是用于布局和定位元素的概念。它由内容区域...