Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
yitter
雪花ID全家桶(SnowFlake IdGenerator)
提交
f0e7c0ff
雪
雪花ID全家桶(SnowFlake IdGenerator)
项目概览
yitter
/
雪花ID全家桶(SnowFlake IdGenerator)
10 个月 前同步成功
通知
201
Star
3
Fork
1
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
雪
雪花ID全家桶(SnowFlake IdGenerator)
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
f0e7c0ff
编写于
4月 05, 2021
作者:
yitter
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
auto commit
上级
40c95cf7
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
65 addition
and
57 deletion
+65
-57
Rust/source/src/lib.rs
Rust/source/src/lib.rs
+65
-57
未找到文件。
Rust/source/src/lib.rs
浏览文件 @
f0e7c0ff
...
...
@@ -20,9 +20,17 @@ lazy_static! {
}
// #[export_name = "SetIdGenerator"]
// // #[export_name = "SetIdGenerator"]
// #[no_mangle]
// pub extern "C" fn SetIdGenerator(options: IdGeneratorOptions) {
// YitIdHelper::SetIdGenerator(options);
// }
#[no_mangle]
pub
extern
"C"
fn
SetIdGenerator
(
options
:
IdGeneratorOptions
)
{
pub
extern
"C"
fn
SetOptions
(
workerId
:
u32
,
workerIdBitLength
:
u8
,
seqBitLength
:
u8
)
{
let
mut
options
=
IdGeneratorOptions
::
New
(
1
);
options
.WorkerIdBitLength
=
workerIdBitLength
;
options
.SeqBitLength
=
seqBitLength
;
YitIdHelper
::
SetIdGenerator
(
options
);
}
...
...
@@ -36,64 +44,64 @@ pub extern "C" fn NextId() -> i64 {
YitIdHelper
::
NextId
()
}
static
mut
TestValue
:
i32
=
0
;
#[no_mangle]
pub
extern
"C"
fn
Test
()
->
i32
{
unsafe
{
TestValue
+=
1
;
return
TestValue
;
}
}
#[no_mangle]
pub
extern
"C"
fn
GetWorkerId
(
ip
:
*
const
c_char
,
port
:
i32
)
->
redis
::
RedisResult
<
isize
>
{
// let c_str = unsafe {
// assert!(!ip.is_null());
// CStr::from_ptr(ip)
// };
//
// let r_str = c_str.to_str();
// connect to redis
// let client = redis::Client::open(format!("redis://{}:{}/", String::from(r_str).to_string(), port))?;
let
client
=
redis
::
Client
::
open
(
format!
(
"redis://localhost:{}/"
,
port
))
?
;
let
mut
con
=
client
.get_connection
()
?
;
// throw away the result, just make sure it does not fail
unsafe
{
let
_
:
()
=
con
.set
(
"my_key111"
,
TestValue
.clone
())
?
;
}
con
.get
(
"my_key"
)
// read back the key and return it. Because the return value
// from the function is a result for integer this will automatically
// convert into one.
//
// static mut TestValue: i32 = 0;
// #[no_mangle]
// pub extern "C" fn Test() -> i32 {
// unsafe {
// TestValue += 1;
// return TestValue;
// }
// }
// match simple_redis::create(&format!("redis://{}:{}/", ip, port)) {
// Ok(mut client) => {
// println!("Created Redis Client");
// #[no_mangle]
// pub extern "C"
// fn GetWorkerId(ip: *const c_char, port: i32) -> redis::RedisResult<isize> {
// // let c_str = unsafe {
// // assert!(!ip.is_null());
// // CStr::from_ptr(ip)
// // };
// //
// // let r_str = c_str.to_str();
//
// let valueString = TestValue.to_string();
// let valueString2 = (*TestValue).to_string();
// // connect to redis
// // let client = redis::Client::open(format!("redis://{}:{}/", String::from(r_str).to_string(), port))?;
// let client = redis::Client::open(format!("redis://localhost:{}/", port))?;
//
// match client.set("my_key", valueString) {
// Err(error) => println!("Unable to set value in Redis: {}", error),
// _ => println!("Value set in Redis")
// };
// let mut con = client.get_connection()?;
// // throw away the result, just make sure it does not fail
// unsafe {
// let _: () = con.set("my_key111", TestValue.clone())?;
// }
// con.get("my_key")
// // read back the key and return it. Because the return value
// // from the function is a result for integer this will automatically
// // convert into one.
// //
//
// match client.set("my_key2", valueString2) {
// Err(error) => println!("Unable to set value in Redis: {}", error),
// _ => println!("Value set in Redis")
// };
// // match simple_redis::create(&format!("redis://{}:{}/", ip, port)) {
// // Ok(mut client) => {
// // println!("Created Redis Client");
// //
// // let valueString = TestValue.to_string();
// // let valueString2 = (*TestValue).to_string();
// //
// // match client.set("my_key", valueString) {
// // Err(error) => println!("Unable to set value in Redis: {}", error),
// // _ => println!("Value set in Redis")
// // };
// //
// // match client.set("my_key2", valueString2) {
// // Err(error) => println!("Unable to set value in Redis: {}", error),
// // _ => println!("Value set in Redis")
// // };
// //
// // match client.quit() {
// // Err(error) => println!("Error: {}", error),
// // _ => println!("Connection Closed.")
// // }
// // }
// // Err(error) => println!("Unable to create Redis client: {}", error)
// // }
//
// match client.quit() {
// Err(error) => println!("Error: {}", error),
// _ => println!("Connection Closed.")
// }
// }
// Err(error) => println!("Unable to create Redis client: {}", error)
// //return 1;
// }
//return 1;
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录