xmpp推送服务smack与springboot结合（三）

image.png

介绍

XMPP协议的推送实现采用的smack库，可以与不同的java框架整合使用，这次我使用的springboot框架实现。

这篇文章主要写代码的实现，对XMPP不清楚的，可以看前几篇文章：

java推送技术的选择（一）
openfire服务的安装（二）

搭建springboot项目

这里写图片描述

pom.xml文件,加入jar包

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>demo</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <!--xmpp  smack-->
        <dependency>
            <groupId>org.igniterealtime.smack</groupId>
            <artifactId>smack-core</artifactId>
            <version>4.1.8</version>
        </dependency>
        <dependency>
            <groupId>org.igniterealtime.smack</groupId>
            <artifactId>smack-tcp</artifactId>
            <version>4.1.8</version>
        </dependency>
        <dependency>
            <groupId>org.igniterealtime.smack</groupId>
            <artifactId>smack-java7</artifactId>
            <version>4.1.8</version>
        </dependency>
        <dependency>
            <groupId>org.igniterealtime.smack</groupId>
            <artifactId>smack-extensions</artifactId>
            <version>4.1.8</version>
        </dependency>
        <dependency>
            <groupId>org.igniterealtime.smack</groupId>
            <artifactId>smack-sasl-provided</artifactId>
            <version>4.1.8</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-snapshots</id>
            <url>http://repo.spring.io/libs-snapshot</url>
        </repository>
    </repositories>

    <pluginRepositories>
        <pluginRepository>
            <id>spring-snapshots</id>
            <url>http://repo.spring.io/libs-snapshot</url>
        </pluginRepository>
    </pluginRepositories>

</project>

与smack结合主要使用的是上面的5个jar包，smack的功能还有很多，需要的可以去看看官方的API文档

1、smack-core.jar XMPP RFC规范定义的XMPP核心功能。

2、smack-extensions.jar XMPP Standards Foundation定义的扩展（XEP）功能。 包括群聊、文件传输、用户搜索等等。

官方文档地址：
http://download.igniterealtime.org/smack/docs/latest/javadoc/

配置openfire地址

#openfire服务器地址
openfire.server=127.0.0.1

发送XMPP消息

连接XMPP服务器

XMPPTCPConnectionConfiguration.Builder config=XMPPTCPConnectionConfiguration.builder();
config.setServiceName(openfireServer);
config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
config.setSendPresence(true);
config.setCompressionEnabled(false);

XMPPTCPConnection con = new XMPPTCPConnection(config.build());
SASLAuthentication.blacklistSASLMechanism("SCRAM-SHA-1");
SASLAuthentication.blacklistSASLMechanism("DIGEST-MD5");
SASLAuthentication.blacklistSASLMechanism("CRAM-MD5");
return con;

实现代码

package com.example.demo;

import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.SASLAuthentication;
import org.jivesoftware.smack.packet.Message;
import org.jivesoftware.smack.sasl.provided.SASLPlainMechanism;
import org.jivesoftware.smack.tcp.XMPPTCPConnection;
import org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration;
import org.jivesoftware.smackx.search.ReportedData;
import org.jivesoftware.smackx.search.UserSearchManager;
import org.jivesoftware.smackx.xdata.Form;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * info:
 * Created by shang on 2017/8/1.
 */
@RestController
public class SmackController {

    @Value("${openfire.server}")
    protected String openfireServer;


    @RequestMapping("")
    public Object index(String mobile, String body) {
        return sendSmackMessage(mobile, body, false);
    }




    public boolean sendSmackMessage(String mobile, String body,boolean deliveryReceiptRequest) {
        try {
            if (StringUtils.isEmpty(mobile)) {
                return false;
            }
            XMPPTCPConnection con = getXmpptcpConnection();
            con.connect();
            if (con.isConnected()) {
                SASLAuthentication.registerSASLMechanism(new SASLPlainMechanism());
                con.loginAnonymously();//匿名登录
                UserSearchManager userSearchManager=new UserSearchManager(con);
                Form searchForm=userSearchManager.getSearchForm("search."+con.getServiceName());
                Form answerForm = searchForm.createAnswerForm();
                answerForm.setAnswer("Username", true);
                answerForm.setAnswer("search", mobile);
                ReportedData data=userSearchManager.getSearchResults(answerForm,"search."+con.getServiceName());
                List<ReportedData.Row> list = data.getRows();

                for (ReportedData.Row row : list) {
                    for (String jid : row.getValues("jid")) {
                        Message m = new Message();
                        m.setBody(body);//设置消息。
                        m.setTo(jid);//设置发送目标
                        if(deliveryReceiptRequest){
                            m.setType(Message.Type.normal);
                        }else{
                            m.setType(Message.Type.headline);
                        }
                        m.setSubject(body);
                        con.sendStanza(m);
                    }
                }
            }
            con.disconnect();
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

    private XMPPTCPConnection getXmpptcpConnection() {
        XMPPTCPConnectionConfiguration.Builder config=XMPPTCPConnectionConfiguration.builder();
        config.setServiceName(openfireServer);
        config.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
        config.setSendPresence(true);
        config.setCompressionEnabled(false);

        XMPPTCPConnection con = new XMPPTCPConnection(config.build());
        SASLAuthentication.blacklistSASLMechanism("SCRAM-SHA-1");
        SASLAuthentication.blacklistSASLMechanism("DIGEST-MD5");
        SASLAuthentication.blacklistSASLMechanism("CRAM-MD5");
        return con;
    }

}

代码解释

  1. getXmpptcpConnection方法为连接XMPP
  2. sendSmackMessage为发送消息的方法，mobile为接收人，body为发送的内容，deliveryReceiptRequest为是否是离线消息
  3. 代码中采用的是匿名发送，也可以指定一个账号作为发送方
  4. 这里我根据需要还用了模糊匹配账号，给匹配的账号都发送了消息
  5. Message.Type.normal与Message.Type.headline是是否离线消息

测试

启动项目后,浏览器输入：http://localhost:8080/?mobile=18758120932&body=测试测试

登录spray客户端，就会接收到消息


这里写图片描述

结束语

以上代码使用就是我在项目中对推送服务的使用，如果在APP内用这样的推送业务，可以选择XMPP服务作为你的选择。

更多的smack的使用可以查看官方文档，聊天，分组，添加好友等功能，完全可以满足你的各种需求。

有问题欢迎给我留言~

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容

  • XMPP(2)
    关于XMPP最权威的讲解：http://www.jabbercn.org/RFC3920（这个才是最权威的，下面文...
    随风飘荡的小逗逼阅读 5,410评论 1赞 5
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 135,441评论 19赞 139
  • Xmpp客户端库Smack(4.1.4)文档整理
    一、Smack库概述     Smack是一个开源、易用的XMPP/Jabber客户端库，它使用Java语言开发，...
    AndryYu阅读 11,446评论 2赞 13
  • 即时通讯：XMPP基础
    即时通讯系列阅读 即时通讯基础 即时通讯：XMPP基础 即时通讯：XMPP项目实践-微聊 Smack类库最好的学习...
    JackChen1024阅读 9,208评论 0赞 11
  • Androi的消息推送机制
    Android消息推送机制研究1.基于HTTP协议的推送机制基于HTTP协议的推送机制是一种请求-响应模式,由于H...
    GB_speak阅读 4,039评论 0赞 2