提交 1642db01 编写于 作者: 檀越@新空间's avatar 檀越@新空间 🐭

fix:发送消息

上级 264aa2d9
...@@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit; ...@@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit;
* @version : 2.2.0 * @version : 2.2.0
* @date : 2023/5/26 14:18 * @date : 2023/5/26 14:18
*/ */
public class OneWayProducer { public class Base_01_OneWayProducer {
public static void main(String[] args) throws Exception, MQBrokerException { public static void main(String[] args) throws Exception, MQBrokerException {
//1.创建消息生产者producer,并制定生产者组名 //1.创建消息生产者producer,并制定生产者组名
DefaultMQProducer producer = new DefaultMQProducer("group1"); DefaultMQProducer producer = new DefaultMQProducer("group1");
......
...@@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit; ...@@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit;
* @version : 2.2.0 * @version : 2.2.0
* @date : 2023/5/26 14:18 * @date : 2023/5/26 14:18
*/ */
public class SyncProducer { public class Base_02_SyncProducer {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
//1.创建消息生产者producer,并制定生产者组名 //1.创建消息生产者producer,并制定生产者组名
DefaultMQProducer producer = new DefaultMQProducer("group1"); DefaultMQProducer producer = new DefaultMQProducer("group1");
......
...@@ -15,7 +15,7 @@ import java.util.concurrent.TimeUnit; ...@@ -15,7 +15,7 @@ import java.util.concurrent.TimeUnit;
* @version : 2.2.0 * @version : 2.2.0
* @date : 2023/5/26 14:17 * @date : 2023/5/26 14:17
*/ */
public class AsyncProducer { public class Base_03_AsyncProducer {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
//1.创建消息生产者producer,并制定生产者组名 //1.创建消息生产者producer,并制定生产者组名
DefaultMQProducer producer = new DefaultMQProducer("group1"); DefaultMQProducer producer = new DefaultMQProducer("group1");
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册