RabbitMQ 进阶- 阿里云服务器部署RabbitMQ集群

如果RabbitMQ集群只有一个broker节点，那么该节点的失效将导致整个服务临时性的不可用，并且可能会导致message的丢失（尤其是在非持久化message存储于非持久化queue中的时候）。可以将所有message都设置为持久化，并且使用持久化的queue，但是这样仍然无法避免由于缓存导致的问题：因为message在发送之后和被写入磁盘并执行fsync之间存在一个虽然短暂但是会产生问题的时间窗。通过publisher的confirm机制能够确保客户端知道哪些message已经存入磁盘，尽管如此，一般不希望遇到因单点故障导致服务不可用。

如果RabbitMQ集群是由多个broker节点构成的，那么从服务的整体可用性上来讲，该集群对于单点失效是有弹性的，但是同时也需要注意：尽管exchange和binding能够在单点失效问题上幸免于难，但是queue和其上持有的message却不行，这是因为queue及其内容仅仅存储于单个节点之上，所以一个节点的失效表现为其对应的queue不可用。

为了提高程序的吞吐量，保持消息的可靠性，一台机器挂了后，RabbitMQ能够正常生产，消费消息。

rabbitmq有三种模式：单机模式，普通集群模式，镜像集群模式

Demo级别的，一般只是本机测试玩玩而已，生产环境下不会用的。

在多台机器上启动多个rabbitmq实例，每个机器启动一个。

但是你创建的queue，只会放在一个rabbtimq实例上，但是每个实例都同步queue的元数据(存放含queue数据的真正实例位置)。消费的时候，实际上如果连接到了另外一个实例，那么那个实例会从queue所在实例上拉取数据过来。

示意图

这种方式确实很麻烦，也不怎么好，没做到所谓的分布式，就是个普通集群。

普通集群的方式，确实达到了消息的高可用，但没办法保证可靠性，没做到分布式，简而言之，只是一个普通的集群。

这种模式，才是所谓的rabbitmq的高可用模式，跟普通集群模式不一样的是，你创建的queue，无论元数据还是queue里的消息都会存在于多个实例上，然后每次你写消息到queue的时候，都会自动把消息到多个实例的queue里进行消息同步。

上图中每个节点有一个queue，生产者生产完毕数据后投递到指定交换机的队列，交换机的队列进行消息同步。

每个节点queue都有一个完整的rabbitmq节点，所以这种方式叫做镜像集群

好处： 任何一个节点宕机后，其它节点不受影响，正常使用

坏处：

确保机器中安装了Docker，若未安装，可看：云原生Docker入门 – 阿里云服务器Linux环境下安装Docker

查看拉取的镜像

成功运行

设置节点1

浏览器输入 您的ip地址:15673

再次测试即可成功~

File —> New —> Project —> Maven —> 直接Next 进入下一步创建普通的Maven工程即可

创建一个默认的Maven聚合工程，将src文件夹删除，该工程就是一个Maven聚合工程

引入依赖如下：

在项目内，新建一个Moudle，rabbitmq-order-producer 默认Maven工程，下一步即可

在项目内，新建一个Moudle，rabbitmq-order-cousumer 默认Maven工程，下一步即可

Maven聚合工程创建完成图

Maven依赖图

自行手写MainApplication即可

创建完成！

编写完成！

启动消费者

交换机

=

15674

15675

成功消费数据！

已成功同步消息~

Docker部署WEB 应用时，本地可以成功打开测试页，在公网上(阿里云服务器)却不能打开。

1、环境：阿里云服务器

2、CentOS7系统

3、Docker成功部署

这里前提docker 已经成功部署啦，现有有一个简单的测试案例，在docker上部署一个应用从而访问web。

接下来让我们尝试使用 docker 构建一个 web 应用程序。

我们将在docker容器中运行一个 Python Flask 应用来运行一个web应用。

通过 -p 参数来设置一样的端口：

docker ps 查看正在运行的容器

容器内部的 5000 端口映射到我们本地主机的 5000 端口上。

这时我们可以通过浏览器访问WEB应用

访问失败

指定外网端口为5000，

1 本地测试能否打开测试页

本地没有问题。

2 浏览器中访问

在任意一台电脑上输入公网IP+端口号 (此端口号为运行WEB应用时指定的端口号5000) 如我的阿里云公网IP为123111111 此时在任意一台有网络的浏览器地址栏输入公网IP：http://123111111:5000 应该会出现测试页

但现在出现如下图所示：

显示打不开

查啦大量资料，以前曾经也解决过，一定弄明白自已购买的地区后，再去设置安全组的配置规则。

1 登录阿里云管理控制台

2找到云服务器ECS-概览

3 点击云服务器ECS，这个是我购买的类型，其他类型的就不清楚啦。

4 点击本安全组后，再次点击配置规则：

5 手动添加端口5000

6 最后保存，再从浏览器地址栏输入公网IP加端口号3344成功显示测试页如图：

将SpringCloud集成Eureka服务部署在阿里云服务器。

项目在上一篇博客讲过在本地测试SpringCloud集成Eureka服务,博客地址：

https://wwwjianshucom/p/78e8797ea804 ,现在将3个项目部署在阿里云服务器，环境是CentOS7，Tomcat 9。

在pomxml文件里设置打包方式：

在启动Application类添加：

在applicationproperties配置文件修改：

直接把项目lean下，再package：

打包后的war包在target目录下：

修改pomxml依赖：

程序入口application类修改：

消费者的api请求路径修改：

applicationproperties修改

直接对项目lean，再package：

3Eureka Client项目demo打包跟1类似，这就不重复写了；

3个项目打包好的包名：springcloud-eurekawar，springcloud-eureka-client-onewar，springcloud-eureka-client-onewar：

4将3个war部署阿里云服务器

登录阿里云的白塔控制面板，将3个包上传到Tomcat的webapps文件夹下：

或者通过xftp工具上传也可以；

上传完后，重启Tomcat，等一会，就可以在浏览器里访问：

相关链接：

成功截图：

1，APP应用需要什么样的云服务器？

为了帮助大家了解如何使用阿里云云服务器及相关应用，阿里云的移动云团队开发了一个简单的APP应用：移动云相册，其中使用了ECS主要用作部署云相册的API服务（信息调用、列表调用）和缩略图处理，因为这个应用服务端使用了JAVA语言开发，因此在上面安装tomcat来部署应用。

具体部署

1）远程登录：

第一次购买ECS后，会把该ECS服务器的root账号、密码发送购买者的邮箱，然后购买者可以通过远程登录到ECS服务器，具体远程登录可以参考如下：

Windows：http://helpaliyuncom/manualspm=51763835185164lLZzn&helpId=59

Linux:http://helpaliyuncom/manualspm=51763835185164lLZzn&helpId=59

2）安装web环境

根据自己应用特点选择安装相关web服务器tomcat或者jetty，阿里云提供了一条龙安装部署脚本，为开发者提供了更多的方便，请参考如下链接：http://helpaliyuncom/manualspm=0000RGeYy4&helpId=129

3）打包应用

将web源码下载到本地，使用命令mvnpackage打成war包。如果不是maven工程，可以用类似ant打成war包。

4）上传war包

Linux下面可以使用sftp上传war包，上传war包到指定目录后进行解压，具体使用方式参考：http://helpaliyuncom/manualspm=0000PnfpSL&helpId=1848

5）启动web服务

将tomcat或jetty服务启动

6）配置反向代理、绑定域名

具体配置信息参考：http://helpaliyuncom/manualspm=0000Ti7iuA&helpId=532, http://helpaliyuncom/manualspm=0000MKbFj1&helpId=65

2，APP应用如何把存到云存储服务器中？

类APP应用的架构核心在于大量小文件的存储与访问，在文件数量较多的情况下将文件直接存储在硬盘上将极大影响应用的访问效率。阿里云存储服务OSS对海量小文件的存储及管理具有很大优势，不从服务端下载，减少了服务端压力。阿里云的OSS的备份机制也保证了文件的存储安全，其存储容量可以无限扩展，每秒请求数超过50000次，多线BGP网络确保全国各地访问流畅。

使用阿里云OSS步骤：

1）登录阿里云官网（aliyuncom）开通OSS

2）获取KEY及密钥

3）下载SDK

（JAVA版下载地址为：http://bbsaliyuncom/jobphpaction=download&aid=38817

帮助手册： http://aliyun_portal_storageossaliyuncscom/oss_api/oss_javahtml/indexhtml ）

4）开始APP开发

很简单吧，下面是一个使用阿里云的OSS上传的代码样例：

StringupLoadURI = OSSClientgenerateUploadUrl(ConstantsSERVER_URLGENERATE_URL,fileName, null);

int status =OSSClientuploadFile(upLoadURI, path);

3，APP上云后如何使用云数据库？

为了帮助大家了解如何使用阿里云云服务器及相关应用，阿里云的移动云团队开发了一个简单的APP应用：移动云相册，其中使用了RDS中提供的MYSQL服务，数据库中主要存储了用户上传的信息，包括原图、缩略图的信息及存储地址，通过WEB端API向客户端提供数据调用。

使用阿里云RDS和使用本地数据库基本上没有区别，使用样例如下：

1）创建数据库实例

使用阿里云账号购买RDS后，可以创建数据库实例。

2）创建数据库以及管理账号

创建数据库名称以及管理账号，用于应用程序调用数据库连接。

3）访问数据库：

创建完数据库（test）后，在数据库test里添加账户：test、密码：test，可以在RDS控制台查看到数据库相关信息，从中能够得到数据库的外网地址如：xxxxmysqlrdsaliyuncscom，可以使用应用程序连接数据库，javajdbc连接数据库示例代码如下：

String url = “jdbc:mysql://xxxxmysqlrdsaliyun:3306/test”;

String username = “test” ;

String password = “test” ;

try{

Connection con = DriverManagergetConnection(url ,username , password ) ;

}catch(SQLException e){

eprintStackTrace() ; //需要对异常做处理

}

　　文档目的

　　本文档介绍了如何快速创建

Linux

系统实例、远程连接实例、部署环境等。旨在引导您一站式完成实例的创建、购买、远程登录和快速环境部署。

　　云服务器

ECS

实例，有时候也被称为阿里云服务器、云服务器、云服务器

ECS

等。为避免引起误解，本文一律使用

云服务器

ECS

实例

这一名称，简称

实例

。

　　读者对象

　　本文档作为快速入门参考，适用于有以下需求的读者对象：

　　了解如何购买

ECS

云服务器实例、部署环境

　　购买了云服务器

ECS，但不知道如何快速部署环境

　　云服务器

ECS

实例中安装

Linux

　　本文档是针对售卖页用户的。API

用户，请参考

API

文档。

　　快速入门流程图

　　下图显示了创建和使用云服务器

ECS

实例的流程。

　　一般购买和使用云服务器

ECS

实例遵循以下步骤：

　　配置选型

　　创建实例

　　登录实例

　　格式化和挂载数据盘

　　部署环境

　　1、到阿里云官网购买一台服务器

　　2、给阿里云服务器挂盘，阿里云有教程这里不讲解，自己看。

Linux 系统挂载数据盘

视频：Linux服务器挂载数据盘

　　3、下载tomcat http://apachearvixecom/tomcat/tomcat-7/v7054/bin/apache-tomcat-7054zip

4、准备三个Java Web项目，

web-home 官网项目

web-api 接口项目

web-admin 管理后台项目

开始配置环境：

　　1、登录申请成功的阿里云服务器中

　　2、编辑bashrc文件

1

vim bashrc

　　文件中默认内容是

# bashrc

# User specific aliases and functions

alias rm='rm -i'

alias cp='cp -i'

alias mv='mv -i'

#ource global definitions

if [ -f /etc/bashrc ]; then

/etc/bashrc

fi

　　3、添加Tomcat 环境变量

# bashrc

# User specific aliases and functions

alias rm='rm -i'

alias cp='cp -i'

alias mv='mv -i'

CATALINA_1_BASE=/alidata/server/tomcat-web-admin-6011

CATALINA_1_HOME=/alidata/server/tomcat-web-admin-6011

CATALINA_1_TMPDIR=/alidata/server/tomcat-yunmai-admin-8011/temp

export CATALINA_1_BASE CATALINA_1_HOME CATALINA_1_TMPDIR

CATALINA_2_BASE=/alidata/server/tomcat-web-home-6022

CATALINA_2_HOME=/alidata/server/tomcat-web-home-6022

CATALINA_2_TMPDIR=/alidata/server/tomcat-web-home-6022/temp

export CATALINA_2_BASE CATALINA_2_HOME CATALINA_2_TMPDIR

CATALINA_3_BASE=/alidata/server/tomcat-web-api-6033

CATALINA_3_HOME=/alidata/server/tomcat-web-api-6033

CATALINA_3_TMPDIR=/alidata/server/tomcat-web-6033/temp

export CATALINA_3_BASE CATALINA_3_HOME CATALINA_3_TMPDIR

#ource global definitions

if [ -f /etc/bashrc ]; then

/etc/bashrc

fi

　　4、重启服务器 reboot

　

1

reboot

　　

配置Tomact服务:

　　1、把下载下来的apache-tomcat-7054zip 复杂3份，重命名

　　　　 tomcat-web-admin-6011zip

1

tomcat-web-home-6022zip

1

tomcat-web-api-6033zip<br> <strong>2、把刚重命名的三个Tomcat把上次到 阿里云云服务器中</strong><br> cd /alidata/server/ <br>　　 本解压文件

unzip tomcat-web-admin-6011zip

unzip tomcat-web-home-6022zip

unzip tomcat-web-api-6033zip

1

<strong>3、修改tomcat-web-admin-6011配置 </strong> <br>　 <strong>修改文件conf\serverxml文件</strong><br>　　

cd /alidata/server/tomcat-web-admin-6011/conf

vim serverxml

找到配置<Server port="8005" shutdown="SHUTDOWN">

修改成<Server port="16011" shutdown="SHUTDOWN">

找到配置<Connector port="8080" protocol="HTTP/11" connectionTimeout="20000" redirectPort="8443" />

修改成<Connector port="6011" protocol="HTTP/11" connectionTimeout="20000" redirectPort="8443" />

找到配置 <Connector port="8009" protocol="AJP/13" redirectPort="8443" />

修改成<Connector port="6110" protocol="AJP/13" redirectPort="8443" />

1

在<Host> </Host>中间添加下面代码，配置Web项目访问路径 <br><Context path="" docBase="/alidata/www/web-admin" />

1

<strong> 修改bin\catalinash 文件 </strong>

cd /alidata/server/tomcat-web-admin-6011/bin

vim catalinash

替换一下配置

CATALINA_BASE 修改替换称 CATALINA_1_BASE

CATALINA_HOME 修改替换称 CATALINA_1_HOME

CATALINA_TMPDIR 修改替换称 CATALINA_1_TMPDIR

cd /alidata/server/tomcat-web-home-6022/conf

vim serverxml

找到配置<Server port="8005" shutdown="SHUTDOWN">

修改成<Server port="16022" shutdown="SHUTDOWN">

找到配置<Connector port="8080" protocol="HTTP/11" connectionTimeout="20000" redirectPort="8443" />

修改成<Connector port="6022" protocol="HTTP/11" connectionTimeout="20000" redirectPort="8443" />

找到配置 <Connector port="8009" protocol="AJP/13" redirectPort="8443" />

修改成<Connector port="6220" protocol="AJP/13" redirectPort="8443" />

1

在<Host> </Host>中间添加下面代码，配置Web项目访问路径 <br><Context path="" docBase="/alidata/www/web-home" />

1

<strong> 修改bin\catalinash 文件</strong>

cd /alidata/server/tomcat-web-home-6022/bin

vim catalinash

替换一下配置

CATALINA_BASE 修改替换称 CATALINA_2_BASE

CATALINA_HOME 修改替换称 CATALINA_2_HOME

CATALINA_TMPDIR 修改替换称 CATALINA_2_TMPDIR

cd /alidata/server/tomcat-web-api-6033/conf

vim serverxml

找到配置<Server port="8005" shutdown="SHUTDOWN">

修改成<Server port="16033" shutdown="SHUTDOWN">

找到配置<Connector port="8080" protocol="HTTP/11" connectionTimeout="20000" redirectPort="8443" />

修改成<Connector port="6033" protocol="HTTP/11" connectionTimeout="20000" redirectPort="8443" />

找到配置 <Connector port="8009" protocol="AJP/13" redirectPort="8443" />

修改成<Connector port="6330" protocol="AJP/13" redirectPort="8443" /><br><br><span>在<Host> </Host>中间添加下面代码，配置Web项目访问路径<span> <br><Context path="" docBase="/alidata/www/web-api" /></span></span>

1

<em>　　</em><strong>修改bin\catalinash 文件</strong><em><br></em>

cd /alidata/server/tomcat-web-api-6033/bin

vim catalinash

替换一下配置

CATALINA_BASE 修改替换称 CATALINA_3_BASE

CATALINA_HOME 修改替换称 CATALINA_3_HOME

CATALINA_TMPDIR 修改替换称 CATALINA_3_TMPDIR

　　

配置Web项目:

　　1、创建Java Web项目 web-admin 到服务器上

　　 cd /alidata/www/

　　 上传web-adminzip 解压unzip web-adminzip

2、创建Java Web项目 web-home 到服务器上

　　　　cd /alidata/www/

　　 上传web-homezip 解压unzip web-homezip

3、创建Java Web项目 web-api 到服务器上

　　　　cd /alidata/www/

　　 上传web-apizip 解压unzip web-apizip

tomcat是一个web容器，java web项目相当与容器中的一个元素 ，当把java web项目部署到服务器的时候 就相当于在容器里面加入了一个元素 tomcat启动的时候 tomcat容器会获得里面元素的相关信息 比如web项目的名称

当用户请求服务器的时候 首先根据请求的一级域名找到你启动的tomcat容器，容器在分析一级域名后面的请求字符窜截取请求的项目名字 ，根据项目名字 把请求信息发给 容器里面与项目名字对应的web项目 然后web项目处理请求 处理完了 将响应信息 发给容器 容器在返回给用户

首先你请求的地址是本机的ip地址 ，这样请求能够发送到本机上 ， 那么怎么给本机的tomcat 呢 这关键点就是 端口了 请求会根据本机上所有开启的程序的端口信息 给相应的程序

tomcat的默认端口是8080 所以你的请求地址需要加上：8080 当然你可以更改tomcat的端口比如80 这样你就不用去在请求地址上加：8080 因为100以内的端口 会自动匹配

这个就是一个简单的。

如果你有 webSphere 或者 weblogic 就需要复杂的配置了。不过基本都差不多。理解思想就可以了。

当我们执行下面的hellopy时，使用的flask自带的服务器，完成了web服务的启动。在生产环境中，flask自带的服务器，无法满足性能要求，我们这里采用Gunicorn做wsgi容器，来部署flask程序。Gunicorn（绿色独角兽）是一个Python WSGI的HTTP服务器。从Ruby的独角兽（Unicorn ）项目移植。该Gunicorn服务器与各种Web框架兼容，实现非常简单，轻量级的资源消耗。Gunicorn直接用命令启动，不需要编写配置文件，相对uWSGI要容易很多。

区分几个概念 ：

WSGI：全称是Web Server Gateway Interface（web服务器网关接口），它是一种规范，它是web服务器和web应用程序之间的接口。它的作用就像是桥梁，连接在web服务器和web应用框架之间。

uwsgi：是一种传输协议，用于定义传输信息的类型。

uWSGI：是实现了uwsgi协议WSGI的web服务器。

我们的部署方式： nginx + gunicorn + flask

web开发中，部署方式大致类似。简单来说，前端代理使用Nginx主要是为了实现分流、转发、负载均衡，以及分担服务器的压力。Nginx部署简单，内存消耗少，成本低。Nginx既可以做正向代理，也可以做反向代理。

正向代理 ：请求经过代理服务器从局域网发出，然后到达互联网上的服务器。

特点 ：服务端并不知道真正的客户端是谁。

反向代理 ：请求从互联网发出，先进入代理服务器，再转发给局域网内的服务器。

特点 ：客户端并不知道真正的服务端是谁。

区别 ：正向代理的对象是客户端。反向代理的对象是服务端。

查看命令行选项 ： 安装gunicorn成功后，通过命令行的方式可以查看gunicorn的使用信息。

直接运行 ：

指定进程和端口号 ： -w: 表示进程(worker)。 -b：表示绑定ip地址和端口号(bind)。--access-logfile：表示指定log文件的路径

作为守护进程后台运行 ：

阿里云服务器默认安装到 /user/sbin/ 目录，进入目录，启动 ngnix:

Ubuntu 上配置 Nginx 也是很简单，不要去改动默认的 nginxconf 只需要将/etc/nginx/sites-available/default文件替换掉就可以了。

新建一个 default 文件，添加以下内容:

修改完成后重启nginx即可。

Ubuntu 上配置 Nginx 另一种方法，cd 到 /etc/nginx/confd 文件夹，新建 xxxconf 文件(xxx 可以是项目名，只要是 conf 文件即可)，写入以下内容：

需要监听 https 请求时，写入以下内容：