資源簡介
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?????????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-ba
?????文件???????1363??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1664??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????2520??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1913??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1597??2018-01-02?16:12??RabbitMQ\rabbitmq-java-ba
?????文件???????2071??2018-01-02?15:20??RabbitMQ\rabbitmq-java-ba
?????文件???????2641??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1148??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1386??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1383??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件????????100??2018-01-02?15:20??RabbitMQ\rabbitmq-java-ba
?????文件????????995??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????2535??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????2827??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件????????785??2018-01-02?15:47??RabbitMQ\rabbitmq-java-ba
?????文件???????1528??2018-01-02?16:09??RabbitMQ\rabbitmq-java-ba
?????文件???????1174??2018-01-02?15:35??RabbitMQ\rabbitmq-java-ba
?????文件????????954??2018-01-02?15:38??RabbitMQ\rabbitmq-java-ba
?????文件??????????0??2017-12-27?15:56??RabbitMQ\rabbitmq-java-ba
?????文件????????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個文件信息
- 上一篇:微信公眾平臺的開發java——視頻教程
- 下一篇:數據庫學生宿舍管理系統詳細報告
評論
共有 條評論