#[derive(Serialize, Deserialize)]
struct Message {msg: String,code: i32,
}async fn index() -> impl Responder {HttpResponse::Ok().body("this is a rust microservice demo")
}async fn plain_text_resp() -> impl Responder {HttpResponse::Ok().body("from /foo")
}async fn json_resp() -> impl Responder {let p = Message {msg: "from /bar".to_string(),code: 0,};HttpResponse::Ok().json(p)
}#[actix_rt::main]
async fn main()  {println!("listening at http://localhost:8080");//nacos::register_service();HttpServer::new(|| {App::new().route("/", web::get().to(index)).route("/foo", web::get().to(plain_text_resp)).route("/bar",web::get().to(json_resp))}).bind("127.0.0.1:8080").unwrap().run();//nacos::ping_schedule();}

use crate::NACOS_SERVER;
use crate::PROVIDER_HOST;
use crate::PROVIDER_NAME;
use crate::PROVIDER_PORT;
use percent_encoding::{utf8_percent_encode, AsciiSet, CONTROLS};
use std::time::Duration;
use async_std::task;const FRAGMENT: &AsciiSet = &CONTROLS.add(b' ').add(b'"').add(b'{').add(b'}').add(b':').add(b',');
///
/// https://nacos.io/
/// http://127.0.0.1:8848/nacos/v1/ns/instance?serviceName=rust-microservice&ip=127.0.0.1&port=8080
pub fn register_service() {println!("register service: {:?}", NACOS_SERVER);task::spawn(async {let client = reqwest::blocking::Client::new();let body = client.post(format!("{}/v1/ns/instance?serviceName={}&ip={}&port={}",NACOS_SERVER,PROVIDER_NAME,PROVIDER_HOST,PROVIDER_PORT).as_str()).send().unwrap().text();println!("{:?}", body);});
}
fn ping() {//// nacos 文档中没有说明 metadata 必选, 测试发现，如果没有 metadata 信息， java 端会有错误//let beat = format!("{{"serviceName":"{}","ip":"{}","port":"{}","weight":1,"metadata":{{}}}}", PROVIDER_NAME, PROVIDER_HOST, PROVIDER_PORT);let  encode = utf8_percent_encode(&beat, FRAGMENT).to_string();task::spawn(async move {let client = reqwest::blocking::Client::new();let _body = client.put(format!("{}/v1/ns/instance/beat?serviceName={}&beat={}",NACOS_SERVER,PROVIDER_NAME,encode).as_str()).send().unwrap().text();println!("ping result:{:?}", _body);});
}pub fn ping_schedule() {println!("ping schedule");loop {ping();std::thread::sleep(Duration::from_secs(1));}
}

nacos::register_service();
nacos::ping_schedule();

@FeignClient(name = "rust-microservice",fallback = OpenFeignRustService.FallbackService.class)
public interface OpenFeignRustService {@GetMapping("/foo")public String foo();@GetMapping("/bar")public Object bar();@Componentpublic static class FallbackService implements OpenFeignRustService{@Overridepublic String foo() {return "foo fallback";}@Overridepublic Object bar() {return new HashMap<>();}}
}@RestController
@RequestMapping("/api/feign")
public class OpenFeignController {@AutowiredOpenFeignRustService rustService;@RequestMapping("/foo")public String foo() {return rustService.foo();}@RequestMapping("/bar")public Object bar() {return rustService.bar();}
}

@RestController
@RequestMapping("/api/rest")
public class RestTemplateController {public static final String SERVICE = "rust-microservice";@Autowiredprivate RestTemplate restTemplate;@RequestMapping("/foo")public String foo() {return restTemplate.getForObject("http://"+SERVICE+"/foo",String.class);}@RequestMapping("/bar")public Object bar() {return restTemplate.getForObject("http://"+SERVICE+"/bar",Object.class);}
}