/*
|
* Copyright 1999-2018 Alibaba Group Holding Ltd.
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*/
|
package com.alibaba.csp.sentinel.dashboard.controller;
|
|
import java.util.Random;
|
import java.util.concurrent.TimeUnit;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import com.alibaba.csp.sentinel.Entry;
|
import com.alibaba.csp.sentinel.EntryType;
|
import com.alibaba.csp.sentinel.SphU;
|
import com.alibaba.csp.sentinel.context.ContextUtil;
|
import com.alibaba.csp.sentinel.slots.block.BlockException;
|
|
@Controller
|
@RequestMapping(value = "/demo", produces = MediaType.APPLICATION_JSON_VALUE)
|
public class DemoController {
|
|
Logger logger = LoggerFactory.getLogger(MachineRegistryController.class);
|
|
@RequestMapping("/greeting")
|
public String greeting() {
|
return "index";
|
}
|
|
@RequestMapping("/link")
|
@ResponseBody
|
public String link() throws BlockException {
|
|
Entry entry = SphU.entry("head1", EntryType.IN);
|
|
Entry entry1 = SphU.entry("head2", EntryType.IN);
|
Entry entry2 = SphU.entry("head3", EntryType.IN);
|
Entry entry3 = SphU.entry("head4", EntryType.IN);
|
|
entry3.exit();
|
entry2.exit();
|
entry1.exit();
|
entry.exit();
|
return "successfully create a call link";
|
}
|
|
@RequestMapping("/loop")
|
@ResponseBody
|
public String loop(String name, int time) throws BlockException {
|
for (int i = 0; i < 10; i++) {
|
Thread timer = new Thread(new RunTask(name, time, false));
|
timer.setName("false");
|
timer.start();
|
}
|
return "successfully create a loop thread";
|
}
|
|
@RequestMapping("/slow")
|
@ResponseBody
|
public String slow(String name, int time) throws BlockException {
|
for (int i = 0; i < 10; i++) {
|
Thread timer = new Thread(new RunTask(name, time, true));
|
timer.setName("false");
|
timer.start();
|
}
|
return "successfully create a loop thread";
|
}
|
|
static class RunTask implements Runnable {
|
int time;
|
boolean stop = false;
|
String name;
|
boolean slow = false;
|
|
public RunTask(String name, int time, boolean slow) {
|
super();
|
this.time = time;
|
this.name = name;
|
this.slow = slow;
|
}
|
|
@Override
|
public void run() {
|
long startTime = System.currentTimeMillis();
|
ContextUtil.enter(String.valueOf(startTime));
|
while (!stop) {
|
|
long now = System.currentTimeMillis();
|
if (now - startTime > time * 1000) {
|
stop = true;
|
}
|
Entry e1 = null;
|
try {
|
e1 = SphU.entry(name);
|
|
if (slow) {
|
TimeUnit.MILLISECONDS.sleep(3000);
|
}
|
|
} catch (Exception e) {
|
} finally {
|
if (e1 != null) {
|
e1.exit();
|
}
|
}
|
Random random2 = new Random();
|
try {
|
TimeUnit.MILLISECONDS.sleep(random2.nextInt(200));
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
|
}
|
ContextUtil.exit();
|
}
|
|
}
|
|
}
|
