firebase-admin的Java集成到服务器
1.添加maven
<dependency>
<groupId>com.google.firebase</groupId>
<artifactId>firebase-admin</artifactId>
<version>6.10.0</version>
</dependency>
2.创建firebase-adminsdk.json文件,在firebase控制台中下载json文件将内容复制到firebase-adminsdk.json中
.
3.直接上工具类
package com.supermonkey.futureready.common.utils;
import com.google.auth.oauth2.GoogleCredentials;
import com.google.firebase.FirebaseApp;
import com.google.firebase.FirebaseOptions;
import com.google.firebase.auth.FirebaseAuth;
import com.google.firebase.auth.UserRecord;
import com.google.firebase.messaging.*;
import com.supermonkey.futureready.common.entity.User;
import com.supermonkey.futureready.common.exception.BusinessException;
import org.springframework.core.io.ClassPathResource;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.Map;
/**
* {@code description: FireBaseUtil Firebase Cloud Message}
* Google_FireBase推送工具类
*
* @author zhangkai
* @version 1.0
* @since 2019/7/5 15:48
*/
@Component
public class FireBaseUtil {
//获取AndroidConfig.Builder对象
private static AndroidConfig.Builder androidConfigBuilder = AndroidConfig.builder();
//获取AndroidNotification.Builder对象
private static AndroidNotification.Builder androidNotifiBuilder = AndroidNotification.builder();
public static FirebaseApp firebaseApp;
private static final String FIREBASE_DB_URL = "https://你的firebase地址.firebaseio.com";
private static final String FIREBASE_STORAGE_BUCKET = "你的firebase地址";
private static final String FIREBASE_PROJECT_ID = "你的firebase地址";
static {
init();
}
public static void main(String[] args) {
try {
FirebaseAuth instance = FirebaseAuth.getInstance(firebaseApp);
UserRecord user = getUserById("some-uid");
System.out.println(user.toString());
} catch (Exception e) {
e.printStackTrace();
}
}
public static void init() {
try {
//设置环境
InputStream serviceAccount = new ClassPathResource("firebase-adminsdk.json").getInputStream();
FirebaseOptions options = new FirebaseOptions.Builder()
.setCredentials(GoogleCredentials.fromStream(serviceAccount))
.setDatabaseUrl(FIREBASE_DB_URL)
.build();
firebaseApp = FirebaseApp.initializeApp(options);
} catch (Exception e) {
e.printStackTrace();
}
}
public static UserRecord getUserById(String uid){
FirebaseAuth instance = FirebaseAuth.getInstance(firebaseApp);
UserRecord user = null;
try {
user = instance.getUserAsync(uid).get();
} catch (Exception e) {
e.printStackTrace();
throw new BusinessException("get user from firebase by uid error");
}
return user;
}
public static UserRecord getUserByEmail(String email) {
try {
// [START get_user_by_email]
UserRecord userRecord = FirebaseAuth.getInstance(firebaseApp).getUserByEmailAsync(email).get();
// See the UserRecord reference doc for the contents of userRecord.
// System.out.println("Successfully fetched user data: " + userRecord.getEmail());
return userRecord;
// [END get_user_by_email]
} catch (Exception e) {
e.printStackTrace();
throw new BusinessException("get user from firebase by email error");
}
}
/**
* {@code description: 创建用户}
*
* @param user
* @author zhangkai
* @since 2019/9/27 11:03
*/
public static UserRecord createUser(User user) {
try {
UserRecord.CreateRequest request = new UserRecord.CreateRequest()
.setEmail(user.getEmail())
.setEmailVerified(false)
//.setPassword(ProjectAbout.PASSWORD)
.setDisplayName(user.getFullName())
.setDisabled(false);
FirebaseAuth instance = FirebaseAuth.getInstance(firebaseApp);
UserRecord userRecord = instance.createUserAsync(request).get();
System.out.println("Successfully created new user: " + userRecord.getUid());
return userRecord;
} catch (Exception e) {
e.printStackTrace();
throw new BusinessException("create firebase user error");
}
}
/**
* 单设备推送
* @param token 注册token
* @param title 推送题目
* @param body 推送内容
* @return
* @throws IOException
* @throws FirebaseMessagingException
*/
public static void pushSingle( String token, String title, String body) throws IOException, FirebaseMessagingException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例为空的情况
if (firebaseApp == null) {
return;
}
//构建消息内容
//Notification(String title, String body, String imageUrl)
Message message = Message.builder().setNotification(new Notification(title, body))
.setToken(token)
.build();
//发送后，返回messageID
String response = FirebaseMessaging.getInstance(firebaseApp).send(message);
System.out.println("单个设备推送成功 : " + response);
}
/**
* 单设备推送
* @param token 注册token
* @param title 推送题目
* @param body 推送内容
* @param map 额外的参数
* @return
* @throws IOException
* @throws FirebaseMessagingException
*/
public static void pushSingle(String token, String title, String body, Map<String,String> map) throws IOException, FirebaseMessagingException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例为空的情况
if (firebaseApp == null) {
return;
}
//构建消息内容
//Notification(String title, String body, String imageUrl)
Message message = Message.builder().setNotification(new Notification(title, body))
.putAllData(map)
.setToken(token)
.build();
//发送后，返回messageID
String response = FirebaseMessaging.getInstance(firebaseApp).send(message);
System.out.println("单个设备推送成功 : " + response);
}
/**
* {@code description: 单设备推送}
* @param token 注册token
* @param title 推送题目
* @param body 推送内容
* @param extra 额外的参数
* @return
* @throws IOException
* @throws FirebaseMessagingException
* @author zhangkai
* @since 2019/10/14 11:24
*/
public static void pushSingle( String token, String title, String body, String extra) throws IOException, FirebaseMessagingException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例为空的情况
if (firebaseApp == null) {
return;
}
//构建消息内容
//Notification(String title, String body, String imageUrl)
Message message = Message.builder().setNotification(new Notification(title, body))
.putData("extra",extra)
.setToken(token)
.build();
//发送后，返回messageID
String response = FirebaseMessaging.getInstance(firebaseApp).send(message);
System.out.println("单个设备推送成功 : " + response);
}
/**
* 给设备订阅主题
* @param tokens 设备的token,最大1000个
* @param topic 要添加的主题
* @return
* @throws FirebaseMessagingException
* @throws IOException
*/
public static void registrationTopic( List<String> tokens, String topic) throws FirebaseMessagingException, IOException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例不存在的情况
if (firebaseApp == null) {
return;
}
//订阅，返回主题管理结果对象。
TopicManagementResponse response = FirebaseMessaging.getInstance(firebaseApp).subscribeToTopic(tokens, topic);
System.out.println("添加设备主题，成功：" + response.getSuccessCount() + ",失败：" + response.getFailureCount());
}
/**
* 取消设备的订阅主题
* @param tokens 设备的token,最大1000个
* @param topic 取消的主题
* @return
* @throws FirebaseMessagingException
* @throws IOException
*/
public static void cancelTopic( List<String> tokens, String topic) throws FirebaseMessagingException, IOException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例不存在的情况
if (firebaseApp == null) {
return;
}
//取消订阅，返回主题管理结果对象。
TopicManagementResponse response = FirebaseMessaging.getInstance(firebaseApp).unsubscribeFromTopic(tokens, topic);
System.out.println("取消设备主题，成功：" + response.getSuccessCount() + ",失败：" + response.getFailureCount());
}
/**
* 按主题推送
* @param topic 主题的名字
* @param title 消息题目
* @param body 消息体
* @return
* @throws FirebaseMessagingException
* @throws IOException
*/
public static void sendTopicMes( String topic, String title, String body) throws FirebaseMessagingException, IOException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例不存在的情况
if (firebaseApp == null) {
return;
}
//构建消息
Message message = Message.builder()
.setNotification(new Notification(title, body))
.setTopic(topic)
.build();
//发送后，返回messageID
String response = FirebaseMessaging.getInstance(firebaseApp).send(message);
System.out.println("主题推送成功: " + response);
}
/**
* 单条Android设备推送消息(和pushSingle方法几乎没有区别)
* @param token 注册token
* @param title 推送题目
* @param body 推送内容
* @throws FirebaseMessagingException
*/
public static void pushSingleToAndroid( String token, String title, String body) throws FirebaseMessagingException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例为空的情况
if (firebaseApp == null) {
return;
}
androidConfigBuilder.setRestrictedPackageName("io.telecomm.telecomm");
androidNotifiBuilder.setColor("#55BEB7");// 设置消息通知颜色
androidNotifiBuilder.setIcon("https://www.shiku.co/images/favicon.png");// 设置消息图标
androidNotifiBuilder.setTitle(title);// 设置消息标题
androidNotifiBuilder.setBody(body);// 设置消息内容
AndroidNotification androidNotification = androidNotifiBuilder.build();
androidConfigBuilder.setNotification(androidNotification);
AndroidConfig androidConfig = androidConfigBuilder.build();
//构建消息
Message message = Message.builder()
.setToken(token)
.setAndroidConfig(androidConfig)
.build();
//发送后，返回messageID
String response = FirebaseMessaging.getInstance(firebaseApp).send(message);
System.out.println("单个安卓设备推送成功 : " + response);
}
/**
* Android按主题推送(和sendTopicMes方法几乎没有区别)
* @param topic 主题的名字
* @param title 消息题目
* @param body 消息体
* @return
* @throws FirebaseMessagingException
* @throws IOException
*/
public static void sendTopicMesToAndroid( String topic, String title, String body) throws FirebaseMessagingException, IOException {
//获取实例
FirebaseApp firebaseApp = FirebaseApp.getInstance();
//实例为空的情况
if (firebaseApp == null) {
return;
}
androidNotifiBuilder.setColor("#55BEB7");// 设置消息通知颜色
androidNotifiBuilder.setIcon("https://www.shiku.co/images/favicon.png");// 设置消息图标
androidNotifiBuilder.setTitle(title);// 设置消息标题
androidNotifiBuilder.setBody(body);// 设置消息内容
AndroidNotification androidNotification = androidNotifiBuilder.build();
androidConfigBuilder.setNotification(androidNotification);
AndroidConfig androidConfig = androidConfigBuilder.build();
//构建消息
Message message = Message.builder()
.setTopic(topic)
.setAndroidConfig(androidConfig)
.build();
String response = FirebaseMessaging.getInstance(firebaseApp).send(message);
System.out.println("安卓主题推送成功: " + response);
}
}