day22/下午/428-尚硅谷-尚融宝-消息发送和接收的代码实现流程的总结

我们再简单总结一下前面我们做的在项目当中整合MQ的步骤啊，第一个步骤是什么？第一个步骤，第一个步骤是不是在我们的项目当中去。啊，创建用户s RP user以及配置管理员的权限呀，对吧？啊这是第一个步骤，然后呢，第二个步骤呢，就是配置虚拟机啊，然后呢，在虚拟机当中啊，给上面我们创建的这个管理员分配管理这个虚拟机的权限，以及管理这个跟嗯这个主机的这么一个权限，好，这是第一个步骤，我们先要房和他的这个管理平台来做这样的两件事情。第二个步骤呢，就是我们创建一个rabbit MQ模块，那么这个rabbit MQ模块里面呢，它有一些通用的配置，其中第一个就是核心的AMMQT，第二个呢就是软，第三个呢就是long，然后接下来呢，就是我们创建了一个啊MQ的这个呢，是帮助我们把对象类型就是债的类型，那对于我们刚才的这个所做的这个项目来说呢，就是呃，短信的那个d to smsd to把。

把那个对象呢，给它转成了Jason格式啊，那这个转成Jason格式的对象的字不出来，存在哪了呢？就存在我们的MQ的消息队列当中，一会我会让大家看一下啊好，然后接下来呢，这个是我们MQ的post，就是常量的一个定义，我们定义的交换机路由和消息队列，然后接下来呢，我们这边呢，又定义了MQ service MQ service呢，就是啊，利用这个交换机路由发送这样的一个消息，那我们呢，啊，其实这句话的意思呢，就是在和MQ建立起连接的基础上呢，啊，创建交换机，然后在交换机当中配置路由，然后要发送这样的一个消息，好，那么我们在我们的啊service当中当然要创建这个smsd to了，对吧？啊，这个是帮助跨边服务访问这个共享对象用的，然后接下来呢，就是S当中引入前面我们刚刚创建的这些MQ的。

这些基本的功能，基本的配置啊，还有一些基本的业务方法，那因为我们把前面的这些东西呢，都封装到了我们的re q这个模块当中，所以呢，我们就直接在service call当中去引入这个Q就行了，然后再接下来呢，我们就添加这个L配置，那么我们的service call呢，实际上就是我们的消息的发送端了，那当然我们的消息的接收端呢，就是我们的service s，所以呢，无论是消息的发送端还是消息的接收端，我们都需要和MQ建立连接，那这样的话呢，这两个微服务的我们都要引入rabbit MQ我们刚刚写的这个模块啊依赖，然后接下来呢，还要创建ma这个文件的配置，那么把rabbit and q呢，在我们的Java应用程序当中呢，把它的这个连接呢，给它创建出来好，那所以呢，这个就是我们无论是消息的生产者还是消息的消费者，都要做这样的一个依赖和这样的一个email的配置的，那作为消息。

呃，生产者端呢，我们要做的呢，就是调用我们刚才啊那个red q模块当中的sign message这个方法就可以了，啊，这是消息的生产者的，那么当然了，调用这个send message方法之前呢，我们要就是把啊这个方法当中需要的这些参数呢，咱们都给它，给它找到对不对，给它组装出来，然后给它传过去就行了，所以呢，MQ service.send message，那这样的话，你就调用前面我们写的这呢这个方法啊这个方法，那这个方法之所以这个消息会直接发送到MQ当中，就是因为他用了a MQ p template来发消息，好，那么消息发出去了之后呢，我们就要去监听消息，要接收消息，那么接收消息呢，我们说就是在我们的。

SMS当中去监听这个消息，那么所以在SMS当中呢，我们就创建了这个监听器，好，那这个监听器呢，它之所以能成为监听器，第一它是被spring容器管理的，也就是说spring容器一启动，这个监听器就写在监听着，好那么核心的听在哪呢？在rabbit类一主解当中，那么它定义了这个算一的方法，就是监听方法，因为我们三的方法是要八角四的方法是吧，所以呢，我们就给它定成监听方法了，然后接下来呢，这嗯，这两个参数目前为止咱们没有用上，就是实际上药用完，然后没用可以把它删掉，然后呢，接下来呢，这块呢，就是SM s c tos Mr c这块呢，就是我们在哪呢。在这个位置。发消息啊，就是你发消息的时候，我看一下我们写的这个，我看看我们写这干嘛。

我们写的代码呢，就是在我们的这个，我找一下啊号里面发的消息吧。看里面哪个地方发的消息，是不是那个好看的息呀，然后在这个地方是吧，这个地方发消息，那这个地方SMF这个MQ service啊，Send message，它指定的这三个参数是不是调用了刚才我们的那个基本模块当中的这这三个值对吧，这是他们三个就是对应的啊，这叫这叫什么叫，嗯，交换机路由和消息啊，然后这边呢，叫交换机路由和消息对吧？然后看监听那边。监听那面呢，就是刚才我们说的这个SMS receiver啊，然后这块呢，我们就先只接收消息就没了，因为这其他的内容我们暂时没有用上，然后呢，这样的话，这里就只接收这个消息，只接收消息之后呢，我们就把这个消息当中的mobile和这个消息当中的message分别把它取出来，那么为发短信而组装一些参数就可以了，那这个发短信的参数呢，就是我们之前曾经组端额的参数了，所以整个的这样的一个流程呢，就是们消息的发送和消息的接收的一个完整的流程啊，然后它的核心呢，就是那面有个发消息，这面有一个接消息啊，然接消息的话，上面这一块重点就是这块的exchange，这个交换机一定要和这面的这个。

你就是发消息的时候指定的这个是在那指定的，关一下看一下发消息的时候，我们是在，嗯。

这个地方是吧，在这个地方不是指定了一个交换机的名字吗？就是发消息时候指定的交换机和路由，然后接下来呢，这面是收消息的时候，指定的交换机和路由一定要对应上。明白吧，你对应不上的话，那你发消息，你投到了A邮箱收消息，你上B邮箱里收，那肯定是收不了的是不是啊，所以说这交量金额是邮箱也插不上往同一个交换机和路由当中去发生了消息，那么啊，这个地方就是最终我们的那个啊队列的名字了啊好，这是整个的一个完整的流程。我们大家做一个简单的总结。