您好,登錄后才能下訂單哦!
今天就跟大家聊聊有關Spring Cloud Admin的使用方法,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結了以下內容,希望大家根據這篇文章可以有所收獲。
Admin 簡介
官方文檔:What is Spring Boot Admin?
SpringBootAdmin是一個用于管理和監控SpringBoot微服務的社區項目,可以使用客戶端注冊或者Eureka服務發現向服務端提供監控信息。
注意,服務端相當于提供UI界面,實際的監控信息由客戶端Actuator提供
通過SpringBootAdmin,你可以通過華麗大氣的界面訪問到整個微服務需要的監控信息,例如服務健康檢查信息、CPU、內存、操作系統信息等等
一、SpringCloud使用SpringBoot Admin
1.1 創建一個SpringBoot項目,命名為admin-test,引入如下依賴
<!-- Admin 服務 --> <dependency> <groupId>de.codecentric</groupId> <artifactId>spring-boot-admin-starter-server</artifactId> <version>2.2.1</version> </dependency> <!-- Admin 界面 --> <dependency> <groupId>de.codecentric</groupId> <artifactId>spring-boot-admin-server-ui</artifactId> <version>2.2.1</version> </dependency>
1.2 啟動類
@SpringBootApplication @EnableAdminServer public class AdminTestApplication { public static void main(String[] args) { SpringApplication.run(AdminTestApplication.class, args); } }
1.3 配置文件
spring.application.name=admin-test management.endpoints.jmx.exposure.include=* management.endpoints.web.exposure.include=* management.endpoint.health.show-details=always # spring cloud access&secret config alibaba.cloud.access-key=**** alibaba.cloud.secret-key=****
1.4 啟動項目
輸入項目地址:http://localhost:8080/applications
二、配置郵件通知
2.1 pom
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-mail</artifactId> </dependency>
2.2 郵件配置
spring.mail.host=smtp.qq.com spring.mail.username=單純QQ號 spring.mail.password=授權碼 spring.mail.properties.mail.smpt.auth=true spring.mail.properties.mail.smpt.starttls.enable=true spring.mail.properties.mail.smpt.starttls.required=true #收件郵箱 spring.boot.admin.notify.mail.to=xxxx@qq.com # 發件郵箱 spring.boot.admin.notify.mail.from= xxxx@qq.com
2.3 QQ郵箱設置
找到自己的QQ郵箱
QQ郵箱 》 設置 》 賬戶 》紅框處獲取 授權碼
我們將 consumer 服務下線后,
接著我們就收到了郵件通知,告訴我們服務關閉了
三、發送釘釘群通知
找到群里面的 群設置 》 智能群助手 》 添加機器人
注意:這里的自定義關鍵詞一定要和項目的關鍵字匹配
獲取 Webhook 到項目中,這個是后面要使用到的
啟動類:
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; import de.codecentric.boot.admin.server.config.EnableAdminServer; import de.codecentric.boot.admin.server.domain.entities.InstanceRepository; @SpringBootApplication @EnableAdminServer public class AdminApplication { public static void main(String[] args) { SpringApplication.run(AdminApplication.class, args); } @Bean public DingDingNotifier dingDingNotifier(InstanceRepository repository) { return new DingDingNotifier(repository); } }
通知類:
import java.util.Map; import com.alibaba.fastjson.JSONObject; import de.codecentric.boot.admin.server.domain.entities.Instance; import de.codecentric.boot.admin.server.domain.entities.InstanceRepository; import de.codecentric.boot.admin.server.domain.events.InstanceEvent; import de.codecentric.boot.admin.server.notify.AbstractStatusChangeNotifier; import reactor.core.publisher.Mono; public class DingDingNotifier extends AbstractStatusChangeNotifier { public DingDingNotifier(InstanceRepository repository) { super(repository); } @Override protected Mono<Void> doNotify(InstanceEvent event, Instance instance) { String serviceName = instance.getRegistration().getName(); String serviceUrl = instance.getRegistration().getServiceUrl(); String status = instance.getStatusInfo().getStatus(); Map<String, Object> details = instance.getStatusInfo().getDetails(); StringBuilder str = new StringBuilder(); str.append("服務預警 : 【" + serviceName + "】"); str.append("【服務地址】" + serviceUrl); str.append("【狀態】" + status); str.append("【詳情】" + JSONObject.toJSONString(details)); return Mono.fromRunnable(() -> { DingDingMessageUtil.sendTextMessage(str.toString()); }); } }
發送工具類
import java.io.InputStream; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import com.alibaba.fastjson.JSONObject; public class DingDingMessageUtil { public static String access_token = "Token"; public static void sendTextMessage(String msg) { try { Message message = new Message(); message.setMsgtype("text"); message.setText(new MessageInfo(msg)); URL url = new URL("https://oapi.dingtalk.com/robot/send?access_token=" + access_token); // 建立 http 連接 HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setDoOutput(true); conn.setDoInput(true); conn.setUseCaches(false); conn.setRequestMethod("POST"); conn.setRequestProperty("Charset", "UTF-8"); conn.setRequestProperty("Content-Type", "application/Json; charset=UTF-8"); conn.connect(); OutputStream out = conn.getOutputStream(); String textMessage = JSONObject.toJSONString(message); byte[] data = textMessage.getBytes(); out.write(data); out.flush(); out.close(); InputStream in = conn.getInputStream(); byte[] data1 = new byte[in.available()]; in.read(data1); System.out.println(new String(data1)); } catch (Exception e) { e.printStackTrace(); } } }
消息類:
public class Message { private String msgtype; private MessageInfo text; public String getMsgtype() { return msgtype; } public void setMsgtype(String msgtype) { this.msgtype = msgtype; } public MessageInfo getText() { return text; } public void setText(MessageInfo text) { this.text = text; } }
public class MessageInfo { private String content; public MessageInfo(String content) { this.content = content; } public String getContent() { return content; } public void setContent(String content) { this.content = content; } }
我們下線一個服務后,就可以看到釘釘群就發了消息的通知
同時,當我們啟動服務的時候,也會有消息通知我們服務啟動了
看完上述內容,你們對Spring Cloud Admin的使用方法有進一步的了解嗎?如果還想了解更多知識或者相關內容,請關注億速云行業資訊頻道,感謝大家的支持。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。