• 大小: 129KB
    文件类型: .rar
    金币: 1
    下载: 0 次
    发布日期: 2021-05-16
  • 语言: Java
  • 标签: rabbitmq  stomp插件  java  

资源简介

rabbitmq实例 包括: 基于java的websocket消息推送,以及spring boot集成方式的消息推送 基于html5的websocke协议实现,html直接与rabbitmq建立链接,进行消息推送和接收 技术学习交流:635278789

资源截图

代码片段和文件信息

package com.xzy.mq;

import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;

public class EmitLog {

  private static final String EXCHANGE_NAME = “logs“;

  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost(“192.168.0.110“);
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();

    channel.exchangeDeclare(EXCHANGE_NAME BuiltinExchangeType.FANOUT);

    String message = getMessage(argv);

    channel.basicPublish(EXCHANGE_NAME ““ null message.getBytes(“UTF-8“));
    System.out.println(“ [x] Sent ‘“ + message + “‘“);

    channel.close();
    connection.close();
  }

  private static String getMessage(String[] strings){
    if (strings.length < 1)
         return “info: Hello World!“;
    return joinStrings(strings “ “);
  }

  private static String joinStrings(String[] strings String delimiter) {
    int length = strings.length;
    if (length == 0) return ““;
    StringBuilder words = new StringBuilder(strings[0]);
    for (int i = 1; i < length; i++) {
        words.append(delimiter).append(strings[i]);
    }
    return words.toString();
  }
}


 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       2531  2018-01-02 08:58  RabbitMQ\1、RabbitMQ介绍及安装.md

     文件       9035  2018-01-02 12:44  RabbitMQ\2、基于 RabbitMQ 的实时消息推送.md

     文件      10894  2018-01-02 16:54  RabbitMQ\3、rabbitmq channel参数详解.md

     文件      92633  2015-09-24 13:20  RabbitMQ\html\jquery\jquery-1.9.1.min.js

     文件      79613  2015-11-09 18:38  RabbitMQ\html\rabbitmq\sockjs-0.3.js

     文件      13227  2015-11-09 18:38  RabbitMQ\html\rabbitmq\stomp.js

     文件       1135  2018-01-10 11:49  RabbitMQ\html\receiveMsg.html

     文件       1632  2018-01-10 11:51  RabbitMQ\html\sendMsg.html

     文件       1016  2018-01-02 15:45  RabbitMQ\rabbitmq-java-base\pom.xml

     文件       1363  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\EmitLog.java

     文件       1664  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\EmitLogDirect.java

     文件       2520  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\EmitLogHeader.java

     文件       1913  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\EmitLogTopic.java

     文件       1597  2018-01-02 16:12  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\NewTask.java

     文件       2071  2018-01-02 15:20  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\README.md

     文件       2641  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\ReceiveLogHeader.java

     文件       1148  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\ReceiveLogs.java

     文件       1386  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\ReceiveLogsDirect.java

     文件       1383  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\ReceiveLogsTopic.java

     文件        100  2018-01-02 15:20  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\recompile.sh

     文件        995  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\Recv.java

     文件       2535  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\RPCClient.java

     文件       2827  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\RPCServer.java

     文件        785  2018-01-02 15:47  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\Send.java

     文件       1528  2018-01-02 16:09  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\mq\Worker1.java

     文件       1174  2018-01-02 15:35  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\rabbitmq\Customer.java

     文件        954  2018-01-02 15:38  RabbitMQ\rabbitmq-java-base\src\main\java\com\xzy\rabbitmq\Producter.java

     文件          0  2017-12-27 15:56  RabbitMQ\rabbitmq-java-base\src\main\resources\application.properties

     文件        249  2017-12-27 15:56  RabbitMQ\rabbitmq-springboot\.gitignore

     文件      47610  2017-12-27 15:56  RabbitMQ\rabbitmq-springboot\.mvn\wrapper\maven-wrapper.jar

............此处省略42个文件信息

评论

共有 条评论