025-发送接收消息测试与关闭server

好，那么我们启动了啊，这个name和。我们测试一下吧，是吧，呃，所以现在呢，我们给这个。这Q啊，或者说里边我们给他发送一些消息，然后我们再来接收一些消息，那这个呢测试啊，呃，官方是给我们提供了，那这个测试啊，用力的大家看。看这段说明啊，看这send and receive messages before sending receive messages，在你发送或者接收啊这个消息之前，我们需要告诉客户端。啊，这个本地的name server，就你那name server地址，因为我们大家知道啊，你不管你是consumer是吧，我们从整体架构。我们从整体架构上来说，它都需要从我们的name里边是不是获取到我们的路由表，是吧，所以这也是。

我们这里边讲过的啊，这里边都讲过的，那你要想从它里边获取到路由表，那怎么样，你得把地址告诉他。所以。Q，啊，提供了多种途径啊，去获取获取这个东西是吧？啊，那么最简单的途径是什么呢？我们使用环境变量谁啊，Name server address，所以我们需要怎么做啊，需要怎么做？很简单，仍然是拷贝它啊。这是给name这个环境变量，给它先赋个值，就是你注意啊，我们在这实际上是要用它官方给我们提供的这两个。嗯。这一个命令，一个命令叫猝死。兔这个命令啊，这个这个命令呢。

他他里边。啊，可以快速的给我们，呃，启动一个producer，然后他也会给我们发送消息。那这个呢，会快速的从我们的Q里边去消费消息，这是相当于是官方给我们提供的两个。DEMO是吧？哎，一个是produce producer DEMO，一个是consumer DEMO，我们可以直接来使用，那你用之前得先把这个，这俩都会从name server这个环境变里面读取我们啊，这个地址name server的地址啊，所以我考不过来。啊，然后。哎，先给他有了这个地址了，呃，再然后拷贝过来。看。是吧，大家看清楚啊，哎，我考虑过来直接看清啊看清。

走。看到没有？这在干嘛？生产数据一会儿就结束了啊。一会儿他就停了，自己又停了啊，这才叫生产数据。好了，没了。是不是就结束了啊？Result true。是不是啊，关闭了，你看就是啊，关闭了连接啊。关闭了这个连接地址，这个result处我们可以看啊，它这这发送的大量的这个消息这一条啊。Send result。这一条。这是一条消息。你看。就是。Send status。这个啊是什么意思，这个东西实际上是我们发送给。呃，这个R以后，那么broker给我们的响应发送的结果，它给我们的响应啊，这个响应里边有什么，你看send status啊，这是OK，我发送成功了，因为我已经收到响应了呀，是吧？然后MIGID大家看到没有，这里边是不是有个消息的ID。

然后消息的，呃，ET MIIT。这个呃，我们在这儿，你看这就和前面的东西我们就结合一块了啊。GID，这是producer生成的，它它是由这样构成的，还有个叫GD，这是broke端生成的。是吧，我们就这和前面的知识就对应起来了啊，这是他生产者。这是他这个这个呃，Broker里边啊，生成的这两个都是ID对吧，然后呢。这是message q。

就就我们的消息队列啊，然后具体的消息队列，这这里边是个集合，然后你看topic topic topic test。Name是这个是吧？QID是一。啊，QID是一，这个QID是零，QID是三，QID2什么意思，几个？几个？这个这个Q01234个。还记不记得？老爷在这儿给大家讲的。嗯，在哪儿了。在哪儿给大家说。啊，是是不是在这儿。在这儿。呃，在这里边在讲这儿的时候，老来给大家说过这个自动，这是什么自动创业topic，因为我们。没有手动创建套码，所以它是自动创建的啊，采用的是什么？呃，Brokeer模式呃。

默认会出现几个队列，是不是四个讲过吧，对不对啊，这是默认的啊默认的你看。执行流程。发送消息前可以先创建啊，但是也可以怎么样也可以。不过这步是可选的，也可以在发送消息时，呃，自动。啊，创建topic。那我们现在就属于自动创建的这个DEMO嘛，它自动给你创建的这个啊好。那整个这个过程我们已经了解到了，现在。这些消息。发进去了，我们从这也可以看到他成功了啊，那我能消费不能，哎，所以我们再来看消费。快速启动一个的是吧。然后我把这个去掉啊。看看清楚，走。就是在消费这些消息。

像不像电影上看的那是吧，屏幕上呱在滚动，就这么来的。这个过程啊。他一直这个，你在那一直等着在那看，哎，大家看到这。是吧，啊，下载完毕了啊，下载完毕了，呃，咱们看啊。他这个也是一条一条的啊，大家从这可以看到这是一条。是不是这是消费的。从这。存款。这是不是一条？

对吧，上面这是不是又有一条对吧，这里边儿有一些具体的，呃，具体的一些一些一些信息，我们可以看一下啊。我们可以看一下啊，这broke name叫什么？这QOS对吧。啊，我就就我们这个机器就看QOS是吧，然后QID是二，它消息消费的啊，QID是二，然后什么store。203。啊Q2235，然后这些。Cluster看到没有，这个classster是o cluster。对吧，我们前面是不是也建这个class了，我们创建给大家说这个创建topic的时候是不是。是谁，Test？Topic test对吧，所以大家看啊，这是什么，这是你消费的消息，具体的body，这你消息啊，消息体在这儿呢，Body就是你具体的这个消息在这。

看到吗？这是这是它消息本身啊，前面这些都属于，其实原数据都属于原数据啊OK。这样的话啊，我们就已经啊知道了。他们一下。结束了啊啊，这样我们就知道了什么呢？呃，我们现在这个welcome to啊，已经启动成功了啊，也可以正常的发送呃，接收消息了。当然，怎么样关闭我们的server，关闭server，你看。是吧，直接大家看，就是它用的都是这个命令啊，现在当。看到没都下，等你关闭的时候先关先关broker。再换name，最后RC复制。

哎，这关闭成功了是吧，然后呢。好吧。现在再看，没了吧。对不对，呃，这两个进程就都没了，OK啊，这样的话，我们这个关闭啊，也就说过了。