doc: update for release v2.3.5

doc: add doc for eventbus package
2026-03-01 00:35:28 +08:00 · 2025-03-06 20:11:21 +08:00 · 2025-03-06 20:02:33 +08:00 · 2025-03-06 15:50:12 +08:00
11 changed files with 1334 additions and 80 deletions
--- a/README.md
+++ b/README.md
@@ -506,9 +506,24 @@ import "github.com/duke-git/lancet/v2/datetime"
 -   **<big>AddMinute</big>** : add or sub day to the time.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddMinute)]
    [[play](https://go.dev/play/p/nT1heB1KUUK)]
+-   **<big>AddWeek</big>** : add or sub week to time.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddWeek)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>AddMonth</big>** : add or sub months to time.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddMonth)]
+    [[play](https://go.dev/play/p/todo)]
 -   **<big>AddYear</big>** : add or sub year to the time.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddYear)]
    [[play](https://go.dev/play/p/MqW2ujnBx10)]
+-   **<big>AddDaySafe</big>** : add or sub days to the time and ensure that the returned date does not exceed the valid date of the target year and month.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddDaySafe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>AddMonthSafe</big>** : add or sub months to the time and ensure that the returned date does not exceed the valid date of the target year and month.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddMonthSafe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>AddYearSafe</big>** : Add or sub years to the time and ensure that the returned date does not exceed the valid date of the target year and month.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#AddYearSafe)]
+    [[play](https://go.dev/play/p/todo)]
 -   **<big>BeginOfMinute</big>** : return the date time at the begin of minute of specific date.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datetime.md#BeginOfMinute)]
    [[play](https://go.dev/play/p/ieOLVJ9CiFT)]
@@ -680,6 +695,45 @@ import optional "github.com/duke-git/lancet/v2/datastructure/optional"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/datastructure/optional.md)]
      

+<h3 id="eventbus"> 9. EventBus is an event bus used for handling events within an application. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">Index</a></h3>
+
+```go
+import "github.com/duke-git/lancet/v2/eventbus"
+```
+
+#### 函数列表:
+
+-   **<big>NewEventBus</big>** : Create an EventBus instance.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#NewEventBus)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>Subscribe</big>** : subscribes to an event with a specific event topic and listener function.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#Subscribe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>Unsubscribe</big>** : unsubscribes from an event with a specific event topic and listener function.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#Unsubscribe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>Publish</big>** : publishes an event with a specific event topic and data payload.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#Publish)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>ClearListeners</big>** : clears all the listeners.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#ClearListeners)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>ClearListenersByTopic</big>** : clears all the listeners by topic.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#ClearListenersByTopic)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>GetListenersCount</big>** : returns the number of listeners for a specific event topic.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#GetListenersCount)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>GetAllListenersCount</big>** : returns the total number of all listeners.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#GetAllListenersCount)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>GetEvents</big>** : returns all the events topics.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#GetEvents)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>SetErrorHandler</big>** : sets the error handler function.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/eventbus.md#SetErrorHandler)]
+    [[play](https://go.dev/play/p/todo)]
+
 <h3 id="fileutil"> 9. Fileutil package implements some basic functions for file operations. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

 ```go
@@ -1423,6 +1477,9 @@ import "github.com/duke-git/lancet/v2/slice"
 -   **<big>EqualWith</big>** : checks if two slices are equal with comparator func.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#EqualWith)]
    [[play](https://go.dev/play/p/b9iygtgsHI1)]
+-   **<big>EqualUnordered</big>** : Checks if two slices are equal: the same length and all elements value are equal (unordered).
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#EqualUnordered)]
+    [[play](todo)]
 -   **<big>Every</big>** : return true if all of the values in the slice pass the predicate function.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#Every)]
    [[play](https://go.dev/play/p/R8U6Sl-j8cD)]
@@ -1522,6 +1579,9 @@ import "github.com/duke-git/lancet/v2/slice"
 -   **<big>Shuffle</big>** : shuffle the slice.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#Shuffle)]
    [[play](https://go.dev/play/p/YHvhnWGU3Ge)]
+-   **<big>ShuffleCopy</big>** : return a new slice with elements shuffled.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#ShuffleCopy)]
+    [[play](todo)]
 -   **<big>IsAscending</big>** : Checks if a slice is ascending order.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/slice.md#IsAscending)]
    [[play](https://go.dev/play/p/9CtsFjet4SH)]
@@ -1668,6 +1728,9 @@ import "github.com/duke-git/lancet/v2/stream"
 -   **<big>Reverse</big>** : returns a stream whose elements are reverse order of given stream.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/stream.md#Reverse)]
    [[play](https://go.dev/play/p/A8_zkJnLHm4)]
+-   **<big>ReverseCopy</big>** : returns a new slice of element order is reversed to the given slice.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/stream.md#ReverseCopy)]
+    [[play](todo)]
 -   **<big>Range</big>** : returns a stream whose elements are in the range from start(included) to end(excluded) original stream.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/stream.md#Range)]
    [[play](https://go.dev/play/p/indZY5V2f4j)]
@@ -1897,7 +1960,9 @@ import "github.com/duke-git/lancet/v2/strutil"
 -   **<big>ExtractContent</big>** : extracts the content between the start and end strings in the source string.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/strutil.md#ExtractContent)]
    [[play](https://go.dev/play/p/Ay9UIk7Rum9)]
-
+-   **<big>FindAllOccurrences</big>** : Returns the positions of all occurrences of a substring in a string.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/strutil.md#FindAllOccurrences)]
+    [[play](todo)]

 <h3 id="system"> 22. System package contain some functions about os, runtime, shell command. &nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">index</a></h3>

@@ -2151,6 +2216,9 @@ import "github.com/duke-git/lancet/v2/validator"
 -   **<big>IsIpV6</big>** : check if the string is ipv6.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/validator.md#IsIpV6)]
    [[play](https://go.dev/play/p/AHA0r0AzIdC)]
+-   **<big>IsIpPort</big>** : check if the string is ip:port.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/validator.md#IsIpPort)]
+    [[play](todo)]
 -   **<big>IsStrongPassword</big>** : check if the string is strong password.
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/en/api/packages/validator.md#IsStrongPassword)]
    [[play](https://go.dev/play/p/QHdVcSQ3uDg)]
--- a/README_zh-CN.md
+++ b/README_zh-CN.md
@@ -507,9 +507,24 @@ import "github.com/duke-git/lancet/v2/datetime"
 -   **<big>AddMinute</big>** : 将日期加/减分钟数。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddMinute)]
    [[play](https://go.dev/play/p/nT1heB1KUUK)]
+-   **<big>AddWeek</big>** : 将日期加/减星期数.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddWeek)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>AddMonth</big>** : 将日期加/减月数.
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddMonth)]
+    [[play](https://go.dev/play/p/todo)]
 -   **<big>AddYear</big>** : 将日期加/减分年数。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddYear)]
    [[play](https://go.dev/play/p/MqW2ujnBx10)]
+-   **<big>AddDaySafe</big>** : 增加/减少指定的天数，并确保日期是有效日期。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddDaySafe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>AddMonthSafe</big>** : 增加/减少指定的月份，并确保日期是有效日期。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddMonthSafe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>AddYearSafe</big>** : 增加/减少指定的年份，并确保日期是有效日期。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#AddYearSafe)]
+    [[play](https://go.dev/play/p/todo)]
 -   **<big>BeginOfMinute</big>** : 返回指定时间的分钟开始时间。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datetime.md#BeginOfMinute)]
    [[play](https://go.dev/play/p/ieOLVJ9CiFT)]
@@ -679,7 +694,46 @@ import hashmap "github.com/duke-git/lancet/v2/datastructure/hashmap"
 -   **<big>Hashmap</big>** : 哈希映射。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/datastructure/hashmap.md)]

-<h3 id="fileutil"> 9. fileutil 包含文件基本操作。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="eventbus"> 9. EventbBus是一个事件总线，用于在应用程序中处理事件。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+
+```go
+import "github.com/duke-git/lancet/v2/eventbus"
+```
+
+#### 函数列表:
+
+-   **<big>NewEventBus</big>** : 创建EventBus实例。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#NewEventBus)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>Subscribe</big>** : 订阅具有特定事件主题和监听函数的事件。支持异步，事件优先级，事件过滤器。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#Subscribe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>Unsubscribe</big>** : 取消订阅具有特定事件主题的事件。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#Unsubscribe)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>Publish</big>** : 发布一个带有特定事件主题和数据负载的事件。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#Publish)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>ClearListeners</big>** : 清空所有事件监听器。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#ClearListeners)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>ClearListenersByTopic</big>** : 清空特定事件监听器。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#ClearListenersByTopic)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>GetListenersCount</big>** : 获取特定事件的监听器数量。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#GetListenersCount)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>GetAllListenersCount</big>** : 获取所有事件的监听器数量。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#GetAllListenersCount)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>GetEvents</big>** : 获取所有事件的topic。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#GetEvents)]
+    [[play](https://go.dev/play/p/todo)]
+-   **<big>SetErrorHandler</big>** : 设置事件的错误处理函数。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/eventbus.md#SetErrorHandler)]
+    [[play](https://go.dev/play/p/todo)]
+
+<h3 id="fileutil"> 10. fileutil 包含文件基本操作。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/fileutil"
@@ -779,7 +833,7 @@ import "github.com/duke-git/lancet/v2/fileutil"
    [[play](https://go.dev/play/p/iLRrDBhE38E)]


-<h3 id="formatter"> 10. formatter 格式化器包含一些数据格式化处理方法。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="formatter"> 11. formatter 格式化器包含一些数据格式化处理方法。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/formatter"
@@ -809,7 +863,7 @@ import "github.com/duke-git/lancet/v2/formatter"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/formatter.md#ParseBinaryBytes)]
    [[play](https://go.dev/play/p/69v1tTT62x8)]

-<h3 id="function"> 11. function 函数包控制函数执行流程，包含部分函数式编程。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="function"> 12. function 函数包控制函数执行流程，包含部分函数式编程。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/function"
@@ -874,7 +928,7 @@ import "github.com/duke-git/lancet/v2/function"



-<h3 id="maputil"> 12. maputil 包括一些操作 map 的函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="maputil"> 13. maputil 包括一些操作 map 的函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/maputil"
@@ -1045,7 +1099,7 @@ import "github.com/duke-git/lancet/v2/maputil"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/maputil.md#GetOrDefault)]
    [[play](https://go.dev/play/p/99QjSYSBdiM)]

-<h3 id="mathutil"> 13. mathutil 包实现了一些数学计算的函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="mathutil"> 14. mathutil 包实现了一些数学计算的函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/mathutil"
@@ -1156,7 +1210,7 @@ import "github.com/duke-git/lancet/v2/mathutil"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/mathutil.md#Combination)]
    [[play](https://go.dev/play/p/ENFQRDQUFi9)]

-<h3 id="netutil"> 14. netutil 网络包支持获取 ip 地址，发送 http 请求。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="netutil"> 15. netutil 网络包支持获取 ip 地址，发送 http 请求。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/netutil"
@@ -1229,7 +1283,7 @@ import "github.com/duke-git/lancet/v2/netutil"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/netutil.md#IsTelnetConnected)]
    [[play](https://go.dev/play/p/yiLCGtQv_ZG)]

-<h3 id="pointer"> 15. pointer 包支持一些指针类型的操作。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="pointer"> 16. pointer 包支持一些指针类型的操作。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/pointer"
@@ -1253,7 +1307,7 @@ import "github.com/duke-git/lancet/v2/pointer"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/pointer.md#UnwrapOrDefault)]
    [[play](https://go.dev/play/p/ZnGIHf8_o4E)]

-<h3 id="random"> 16. random 随机数生成器包，可以生成随机[]bytes, int, string。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="random"> 17. random 随机数生成器包，可以生成随机[]bytes, int, string。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/random"
@@ -1319,7 +1373,7 @@ import "github.com/duke-git/lancet/v2/random"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/random.md#RandNumberOfLength)]
    [[play](https://go.dev/play/p/oyZbuV7bu7b)]

-<h3 id="retry"> 17. retry 重试执行函数直到函数运行成功或被 context cancel。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="retry"> 18. retry 重试执行函数直到函数运行成功或被 context cancel。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/retry"
@@ -1353,7 +1407,7 @@ import "github.com/duke-git/lancet/v2/retry"



-<h3 id="slice"> 18. slice 包含操作切片的方法集合。&nbsp; &nbsp; &nbsp; &nbsp; <a href="#index">回到目录</a></h3>
+<h3 id="slice"> 19. slice 包含操作切片的方法集合。&nbsp; &nbsp; &nbsp; &nbsp; <a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/slice"
@@ -1421,6 +1475,9 @@ import "github.com/duke-git/lancet/v2/slice"
 -   **<big>EqualWith</big>** : 检查两个切片是否相等，相等条件：对两个切片的元素调用比较函数 comparator，返回 true。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#EqualWith)]
    [[play](https://go.dev/play/p/b9iygtgsHI1)]
+-   **<big>EqualUnordered</big>** : 检查两个切片是否相等，元素数量相同，值相等，不考虑元素顺序。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#EqualUnordered)]
+    [[play](todo)]
 -   **<big>Every</big>** : 如果切片中的所有值都通过谓词函数，则返回 true。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#Every)]
    [[play](https://go.dev/play/p/R8U6Sl-j8cD)]
@@ -1496,6 +1553,9 @@ import "github.com/duke-git/lancet/v2/slice"
 -   **<big>Reverse</big>** : 反转切片中的元素顺序。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#Reverse)]
    [[play](https://go.dev/play/p/8uI8f1lwNrQ)]
+-   **<big>ReverseCopy</big>** : 反转切片中的元素顺序, 不改变原slice。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/stream.md#ReverseCopy)]
+    [[play](todo)]
 -   **<big>Reduce<sup>deprecated</sup></big>** : 将切片中的元素依次运行 iteratee 函数，返回运行结果。(废弃：建议使用 ReduceBy)
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#Reduce)]
    [[play](https://go.dev/play/p/_RfXJJWIsIm)]
@@ -1520,6 +1580,9 @@ import "github.com/duke-git/lancet/v2/slice"
 -   **<big>Shuffle</big>** : 随机打乱切片中的元素顺序。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#Shuffle)]
    [[play](https://go.dev/play/p/YHvhnWGU3Ge)]
+-   **<big>ShuffleCopy</big>** : 随机打乱切片中的元素顺序, 不改变原切片。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#ShuffleCopy)]
+    [[play](todo)]
 -   **<big>IsAscending</big>** : 检查切片元素是否按升序排列。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#IsAscending)]
    [[play](https://go.dev/play/p/9CtsFjet4SH)]
@@ -1615,7 +1678,7 @@ import "github.com/duke-git/lancet/v2/slice"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/slice.md#ConcatBy)]
    [[play](https://go.dev/play/p/6QcUpcY4UMW)]

-<h3 id="stream"> 19. stream 流，该包仅验证简单的 stream 实现，功能有限。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="stream"> 20. stream 流，该包仅验证简单的 stream 实现，功能有限。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/stream"
@@ -1711,7 +1774,7 @@ import "github.com/duke-git/lancet/v2/stream"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/stream.md#LastIndexOf)]
    [[play](https://go.dev/play/p/CjeoNw2eac_G)]

-<h3 id="structs"> 20. structs 提供操作 struct, tag, field 的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="structs"> 21. structs 提供操作 struct, tag, field 的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/structs"
@@ -1748,7 +1811,7 @@ import "github.com/duke-git/lancet/v2/structs"
 -   **<big>IsTargetType</big>** : 判断属性是否是目标类型。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/struct.md#IsTargetType)]

-<h3 id="strutil"> 21. strutil 包含字符串处理的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="strutil"> 22. strutil 包含字符串处理的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/strutil"
@@ -1897,8 +1960,12 @@ import "github.com/duke-git/lancet/v2/strutil"
 -   **<big>ExtractContent</big>** : 提取两个标记之间的内容。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/strutil.md#ExtractContent)]
    [[play](https://go.dev/play/p/Ay9UIk7Rum9)]
+-   **<big>FindAllOccurrences</big>** : 返回子字符串在字符串中所有出现的位置。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/strutil.md#FindAllOccurrences)]
+    [[play](todo)]

-<h3 id="system"> 22. system 包含 os, runtime, shell command 的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+
+<h3 id="system"> 23. system 包含 os, runtime, shell command 的相关函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/system"
@@ -1948,7 +2015,7 @@ import "github.com/duke-git/lancet/v2/system"



-<h3 id="tuple"> 23. Tuple 包实现一个元组数据类型。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="tuple"> 24. Tuple 包实现一个元组数据类型。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/tuple"
@@ -2065,7 +2132,7 @@ import "github.com/duke-git/lancet/v2/tuple"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/tuple.md#Unzip10)]
    [[play](https://go.dev/play/p/-taQB6Wfre_z)]

-<h3 id="validator"> 24. validator 验证器包，包含常用字符串格式验证函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="validator"> 25. validator 验证器包，包含常用字符串格式验证函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/validator"
@@ -2151,6 +2218,9 @@ import "github.com/duke-git/lancet/v2/validator"
 -   **<big>IsIpV6</big>** : 验证字符串是否是ipv6地址。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/validator.md#IsIpV6)]
    [[play](https://go.dev/play/p/AHA0r0AzIdC)]
+-   **<big>IsIpPort</big>** : 检查字符串是否是ip:port格式。
+    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/validator.md#IsIpPort)]
+    [[play](todo)]
 -   **<big>IsStrongPassword</big>** : 验证字符串是否是强密码：（字母+数字+特殊字符)。
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/validator.md#IsStrongPassword)]
    [[play](https://go.dev/play/p/QHdVcSQ3uDg)]
@@ -2200,7 +2270,7 @@ import "github.com/duke-git/lancet/v2/validator"
    [[doc](https://github.com/duke-git/lancet/blob/main/docs/api/packages/validator.md#IsChinaUnionPay)]
    [[play](https://go.dev/play/p/yafpdxLiymu)]

-<h3 id="xerror"> 25. xerror 包实现一些错误处理函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>
+<h3 id="xerror"> 26. xerror 包实现一些错误处理函数。&nbsp; &nbsp; &nbsp; &nbsp;<a href="#index">回到目录</a></h3>

 ```go
 import "github.com/duke-git/lancet/v2/xerror"
--- a/cryptor/rsa_private_example.pem
+++ b/cryptor/rsa_private_example.pem
@@ -1,51 +1,51 @@
 -----BEGIN rsa private key-----
-MIIJKAIBAAKCAgEA77XqVTCS3dmAd5FnAvrTPcXrVetPzJeksmqqu4EjFv6Fe4NF
-dZQIWtkjgJQ4v27KpZXUL2ExkJhodrfRegHFgq9xiy822umUu6bCyBva1YxFQPev
-KqgPLY7n6wB3PJRnwnSszQCsUDyBC8JnqbeL41qcRiBAjXSh0BFMERSl3F0AViGk
-VCRCmKuc9612Gi6iuw11cFbLUPqLL+YNk+NIgW398nYUUNeacMG12h02n3YJ8HD5
-Q16PhdJ7Z93aAsDgKzl7dT5tyyv3w2p2wOse1GPMfQffZQA+gXmw7+GJImJu3DtW
-KY0cQqzO1Wsa5t+YxMf0A12AYGJa+Y0aPgr8Vl8LY++NdujnazwsgzTJm94uuqHZ
-iv+mtsYIpkLbuMWmBce05G8MtS0O9IabgBLxrbUQvYk9Myv/ff4BgWkO06SAUq7G
-GUn0cI+EglyYYJCgeeBSQid7daQ8M4Idb9veGo2f7KJqHecRf3fzRwlbMMjoo0Nw
-19FAx/tQm1LTg1NxCaheAFI1UzUTCUAZE/X9QwviTuHXTnfjd0wfxeVaJRMyK9ef
-OJuALAit9rtxyfm1fPRztvPwIrpy/wMUQ+7i8xAEPWa+kXFtVLTqEwGnX3QYZf/N
-GJ/9RZmtpcxgpHIJ6OEyqVUYKKeU7R3uW7i3pv3au9lZ5Id1AvAqQWG8TvkCAwEA
-AQKCAgAdC5jiS6lwEju7wTWPKd9Qu9uhJIsdyj4dlEktwR8EWUDJT4WqEo7Umzzv
-Boa9w2nwmHAGcat0ztLRl8JdGzvYcvO6HrVx3x2zgyhU4PMqLv3xOlHSRFzac1ds
-pTjNcVoFOOf7SxqV+k7UovC2otPjb4ZCBQRtX3V/5aim5S6XvfkddqQXwfED2L+D
-T1RhJcd4DNBvFUU7gbA91I1OnxqY/D/qEh6yEP3YrdAgJqwItF/N75J0dE/FslRb
-qIkTDlXbRvLLqQ3asXArEIplI9gvegw8FikebuIkBB/JYTWhofW238W38S48cf35
-5Cl1UiCLr4LEqZ61jxVg6ZUFcYVTodN5/G9CG0/VSNePWaRrNiT2NFRRhOPzKdQd
-RjC4ohWPJuHNa5dcXkjQZAodL70qRwluzcXZUg7KkPGX8zE9BVyZftymHN3EvhY+
-GDFIpBtsKejEEHvUD9AwcSxlh/dawTfiRWi3NpkhA9JGkEDVGINpZsrB33j0aZeP
-eEcFL7BfAgsC7mt+iNAc9kD/2qPEEJgVm+YIPiotg6vvEMgMZM6tCfZCEmSy6R8O
-zN5qBEa0iweQzjd5wzwSpCabB2HMOSNJg2yZYiLubNjSoeqv+KJuVVcDnPCFpSYW
-TczngaAn5S+CZKsm9inDGACiReqe9JZcDw8/I7PV/k3N2pCKkQKCAQEA/G0/LX01
-cnyu081H6wXbiSxzs+nWnETR6ZUduKEv1kU4FKCsHxI1n5XhXUX5/KVt0ttgLMcP
-qPd6XiUmJngPy/s0WWkvHPBj5C95VEsPT4CeVrRKCDdB/LN60n0gkFZanxatkM8i
-unV3vmoOJitS7mG4z9LWkL+PPyTRtlwNSsSHWQqpqjC8klzkvzyyxbVZvrfMPaFW
-MFkLzM2hTHHdBtW6SqTsnTma319T/LXg/fmJd/A8ZNVFU1vafTgdPFVsy9PUb7/L
-eMmzY5PgbK0qFyuHV12Nbh2jaM7ijsBrNa7lD90fRmuXOAXo1YaQLcL9wLnYVqpO
-I+FAwSeNT+CTPQKCAQEA8xqWXeSWncf7Bh3IYuKjyJNeMhoy6idAdKtE5TQoUyXV
-Qtxf2v6ogYoCmJH+mLhwXNmnRpVPQvBlYLvtwV+6cfvjEMnhEXTUa0a3Q3Iz58qk
-+wghBheZcMlJETcQISxt3kSILK9/HP7RsiTrDGgDdsRdHWBHx+BsZQBDu6gwieWk
-4ztSe9amrhpQAzMH/5T4FkKmXIaPRlWXsz3PNWr/+CVSa7LjnmAvriCzD0oMzzkK
-F/XlVmPBTPuuGz3j5rgXTlwaeaa0u4napMKQwb7MQe3nA9GMStp9KQuGu+06zF9Z
-p+VEzg1TVfBFDlqiGXtzhiMHHqRtQVdrVKN3zjX2bQKCAQEA660EA3CXaiDHCbDr
-qJ57bgM2s49rc9M9ORyj9zFm/GL8DSZGDWxu7GR/WRpwYFYDx45SqPvhvxvv/94n
-VFtcRFJxedkex6IZYX6BhRXfYZbwPnttc2ZEEa9wyP1SXfCCA26k9kKuZfAusHVM
-aI6iizZp2n87HUH8eDPkKKKhNmFvDM9LwT5nkS9x0qrVLoo3FD1+TzxGwDUjMz/5
-jOnyNuNtXyvETrbtxge23obhXb6Rfo2plWsZos5rm+W8Rgxr25IXEY68ZjXLavkx
-28WBOsjFP+h0l47MdppSJH26mxCDhOAqxxDEyuWZkWJlUpRvXnUlayTud8ljL/PB
-mAZQ8QKCAQBxpiZRssGu9YSm8Vly0R1ccXiB17mhucPqRv8oX9/SL0epwDiXuqGw
-HYLlLKtnXiI5Zg9LchXh51ydgn29/zC8hNM8UASGEqYTmLWoNEWLwTKroLs/i9zR
-22frQmCqAYlDdaprqYe1WHNT4up3nFCyP06AozgrewFxnlQL8K7waIlTKbJ/7nNx
-xR9Ov5anp07rqTD45HcqnG0VAHpUMLeFnH0RmEnNCo5/yw2qwiWG4tWTKgOTBYOi
-p65XUfGvNLTAj1JZONQZMHMkv0jJKpd24u8y283IWKhWfer5BAiO7qyNTyOBaL1i
-2baO5VQOsaXqOYnki14ARAwLP3iM0LFpAoIBABAIK+w9H+Vndiwq6NV68qHoSQxz
-Cc6EFXGPinIZygK0+4g+cU0pjor1+uCBE6rJsohUwaQE5gIGmiSv0rlRSIg7AWps
-CJneq4id2OVSAVWSItkrtxxwd+W96tDmC/8jdjZGoxwezQWvknEX3qn+W8bjd2TC
-zEsVmzHkRFI2ZONa31ReDYl4HDe938wFjg4dZ5x4Up0bibXEePkPDgZ5IgTD5Ltz
-aEBm0NU6GEk2Gv+r3O6GWbk09AV665GSWdtHNA3ymF7hBGCW92wj26t9qY/PZIEM
-Z4/G6/x4YXoHNtI2BOw8OkpX735I+Jp5Ngvnr6PyAhOnpPaq4utYumypQrU=
+MIIJKAIBAAKCAgEAqX8BaBwlCUfe+J0D+bkRNky0/6aBVhxeeoIJY4FFdgewnloX
+Lc7vxRVgwpUvx1n/FkvulPFCOT65zDSV2kpgm3IZ8Y+gTlRg1S5Cu7QEsirlENhc
+H4NMewpDWiTosS5G6+H8P5stf+do0u4TAoYifmE3JjEI2ewchfSGqy3YIzunVVOn
+YSwAETOjXttLOYs7LLHQa2REo4fDaAVKebUv+aA4ldXvPlK16Nxf2JESNh4oeHxU
+gBvcxkQDQDet7p7G30m/mNfVNeZJi5uOwnO1KIomAT8UosPoANpOXqtq1a4k7Udr
+IOJT6cXdFJ0byOdAfi5PlT0qOP4LtMs65SkmL3QoY9lvX2jBlfjNiOc5uJtcvvYa
+d2AMxqaeoig/xRYoUu0PNtbYjuzFkgYw7Tw3qcEOu9kZeTPUMQJoix54CgekBxeB
+jxCKGJ0UPTAfcEzfhMqMWqPKCFcV8v50/bbsFTNksdJLEkl9Fv8in01YNIYid8OV
+0vYHt8liu7u76sZ59fpJJwOqboAqg58IUFXPiwrNrVRUwRYWbZcDfcQ/hUZDNbJM
+DRSfK1HdyUlWxuhqf/GQ8RXvD/vuUy1ZHR+2IfHzoNCF0qqIFta6YWQsyVjRJe+v
+8IjiPAdpn4BCGB0l4W0oKJMDcZmJq6SjFFQm7pdUXDkWbhDQ4GStvpUrZRsCAwEA
+AQKCAgBtKehdBitwU8KuemoSDvif8T1tne6U6EaNPm0PkjWLdB5zjnB5R1szorYj
+/HO+QB9DW/o4IT5WoiiF9aRB6D9aPl2pL6i+aifHhTjjrWiM24WWmNKUVTsPz6db
+SoQ3gSeaSnzs9mOSihcAKudBa+SRYsljJpedyyz/tWJ6o1ceMhBuqycVNYKBkbF5
+qWFEmYCuI4OpdvWiIRFgUHAL/P7+Fgv7rMKecCTK6gws7ho9kqTcHK9LpyZE5470
+cCfslIRfUR8+MFwYj830RWbnpCAcEQWzLc57mhM1YWSyIlL3dmZAEAxWLI6A9LeT
+zDAV76Kg4fDNnIwyEqS1d2LiLuNxBf5hR8wC+kNLtvv+83vgShUeZVUk/89WKCVw
+oxeAhwHIvniVXkBocoVRM9Nsz7FjbNTGJTvnAMtIvvmKREaa2qe6kSN45Q3GaRKa
+uGr1BbdaEGUZSLU24N7kp7rp4S1H5nqc7iyBVxq+ZBxXAET6JFiY8BawWYhITscz
+LeWzl47fbLHyK0wZDaQAMB18GtIvnEVNI/p86PHxcvqJ1kXXiiVohB5oXx9auPgH
+GgTdWgb7nnCISsWvPW46kp8lAzOpFpWOyCKHCJkXWOpeBeqaaj+HU2mhOyWaH1tk
+h19pwr47f1HLDk0moruTXEBbNaS3vvNyxFGa0gcQUlC6Zc9sgQKCAQEAxbmxCUlb
+/0bH65LUhjyWsteizccRZ7tqeyDeNpWMe+M7La4SmeS3Ru0ksX9prjzWNHHnU4FB
+L+YOeNOexF7EHPZJFt4w4YX6mL6Z39jZfEu3taXrUwqeIem5qOdlZy7pGD9YLAWY
+ZhhPFoYLOFy+I1gNULgjaTKTIkoCwFqust3Ig3m2uY3q5QEwYRVwMCwerba96LV2
+onNhaDVlehkaynCL16bb5xXJpuExWTMoZz92BjpluzGeNvmGZKzA1oWeXc8dSVp+
+iq4Xd5ahGH0Nu0XPpxoz2CEfTOgpWO2hpNvYnmv9iDkVM8K3X3IHNjlkWUodRwHq
+YhxwdkgdUcCpWwKCAQEA23NtdUSVJD1GZ6xXBDsZu5sRk8uZhGaAxpCqWjB0i+sH
+NnJZXnabWXao97ly/X8tZUw2rDE9H7ycRhBT11SvhRj6JPe1WPOvJ5i/wjEMp5yX
+OCreapNlrsKldU/210YYt66R00onvUrfwFK2IKOy1ZkFMDs/rDizuiAqJ8O/FhmY
+1iBiOq4lZ7xIVIsFszN75kgez6GXFMGL3vb36l9kaaJVRg7TAKUOq/Vn7s4WZKkK
+3nLrFuuyS3hmR31BYqDa8043A1sBR/JnVrw3BgNqoS129NOlMJB2d6W/3RsqVZKm
+XksNcz3bsqBQKbsSKbyr5jwpu0F99ARauCzR/ik/QQKCAQArIAMi+WMdXHzCPrYn
+yRM9Upbptt9u9ouU62hME3Yel0MTBYJ9Gkt3JsX4CMgt/orhyW4g4nIrVkwVwmJA
+hkLT5kuutyuGJMixg/Dfx9Y3q/QXpGadKBWxY97gngeZ57tjVH2QrG++5NJrITVV
+R7UY1F2jG2ZtzWAV/Hp5Jc4wqPrQ4j0eX3u6EvZQVnKvrw/J56+oD9weNngqWGsX
+pF4ZhU6a7IPN9QyUX016HRRU4JyHYzlJCNtvNiE/2AX/RAl0gHXsx9YNvUbVCH9+
+bdgO3n0Z/zcLjr3a8lACW2IEKQcoFnmnunuLXI7OPHqiMwZWCzozgJF0cKt+wN/U
+Muc9AoIBAQDKK1SzrDMZ57ls2UBxDWFvjDRtTCxp5WTNiYjm/azhGezTJBVhCTOk
+/8Q6NAbTss5HfCcCC3qcOk5d3bzfq4znuVL5q5rOD/FVMUu3wyg9Ye2OOTAeTxxm
+G7wCj2CAgntS/OgrFy31HX102L4g465lSUuWW38VUkeBORCdAaCQ45QB8GOOW9Dp
+HNKL6lYph2G0PpRnjRpUsVg63UJ3kfLaVnV6OJKvcT+dl8BiarnoTP6KzSZMRpY
+nNrdEW+jRT1w2KWl2bkcZxz8svid+ZfKVPA6LKEKVIxPPcu8DsK5gxjx1YLWoC4+
+KaKwTz80ZDSZLuPjNzqqCzjoY6Ix3B4BAoIBABBWQ0J+m1TM/x6piSAj3Bxz/de8
+ArXVR47NDShegmUiJ9I9SfXJWyvMi7E5tQqOcl8BZymgwjEojGGeNwIXhoVRPiyr
+8x64aCO7tBhzGiGauHXWfJeNF3ASSl0A6LAU/cTnZRmHDpbicEJ1vkvkMbVoOVtW
+sIBzCz0CAStRBPNWZEePl1RDLoQkOEbnLHBJuEBEBSeOXgu3EIXB8vuv3uNYZGX2
+QAXjEhw+jMkluLrfIgtOCGIiY+ai9mLFdVgCDZZDrLUU9Ty0Re9UooxDhUdyteSB
+4l07NzrxRT64Gmsq2nNh2gsZ6EegZxW/ci7rrH0Fu6pE3x+QJ+jFdtMvjNo=
 -----END rsa private key-----
--- a/cryptor/rsa_public_example.pem
+++ b/cryptor/rsa_public_example.pem
@@ -1,14 +1,14 @@
 -----BEGIN rsa public key-----
-MIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEA77XqVTCS3dmAd5FnAvrT
-PcXrVetPzJeksmqqu4EjFv6Fe4NFdZQIWtkjgJQ4v27KpZXUL2ExkJhodrfRegHF
-gq9xiy822umUu6bCyBva1YxFQPevKqgPLY7n6wB3PJRnwnSszQCsUDyBC8JnqbeL
-41qcRiBAjXSh0BFMERSl3F0AViGkVCRCmKuc9612Gi6iuw11cFbLUPqLL+YNk+NI
-gW398nYUUNeacMG12h02n3YJ8HD5Q16PhdJ7Z93aAsDgKzl7dT5tyyv3w2p2wOse
-1GPMfQffZQA+gXmw7+GJImJu3DtWKY0cQqzO1Wsa5t+YxMf0A12AYGJa+Y0aPgr8
-Vl8LY++NdujnazwsgzTJm94uuqHZiv+mtsYIpkLbuMWmBce05G8MtS0O9IabgBLx
-rbUQvYk9Myv/ff4BgWkO06SAUq7GGUn0cI+EglyYYJCgeeBSQid7daQ8M4Idb9ve
-Go2f7KJqHecRf3fzRwlbMMjoo0Nw19FAx/tQm1LTg1NxCaheAFI1UzUTCUAZE/X9
-QwviTuHXTnfjd0wfxeVaJRMyK9efOJuALAit9rtxyfm1fPRztvPwIrpy/wMUQ+7i
-8xAEPWa+kXFtVLTqEwGnX3QYZf/NGJ/9RZmtpcxgpHIJ6OEyqVUYKKeU7R3uW7i3
-pv3au9lZ5Id1AvAqQWG8TvkCAwEAAQ==
+MIICIjANBgkqhkiG9w0BAQEFAAOCAg8AMIICCgKCAgEAqX8BaBwlCUfe+J0D+bkR
+Nky0/6aBVhxeeoIJY4FFdgewnloXLc7vxRVgwpUvx1n/FkvulPFCOT65zDSV2kpg
+m3IZ8Y+gTlRg1S5Cu7QEsirlENhcH4NMewpDWiTosS5G6+H8P5stf+do0u4TAoYi
+fmE3JjEI2ewchfSGqy3YIzunVVOnYSwAETOjXttLOYs7LLHQa2REo4fDaAVKebUv
+aA4ldXvPlK16Nxf2JESNh4oeHxUgBvcxkQDQDet7p7G30m/mNfVNeZJi5uOwnO1
+KIomAT8UosPoANpOXqtq1a4k7UdrIOJT6cXdFJ0byOdAfi5PlT0qOP4LtMs65Skm
+L3QoY9lvX2jBlfjNiOc5uJtcvvYad2AMxqaeoig/xRYoUu0PNtbYjuzFkgYw7Tw3
+qcEOu9kZeTPUMQJoix54CgekBxeBjxCKGJ0UPTAfcEzfhMqMWqPKCFcV8v50/bbs
+FTNksdJLEkl9Fv8in01YNIYid8OV0vYHt8liu7u76sZ59fpJJwOqboAqg58IUFXP
+iwrNrVRUwRYWbZcDfcQ/hUZDNbJMDRSfK1HdyUlWxuhqf/GQ8RXvD/vuUy1ZHR+2
+IfHzoNCF0qqIFta6YWQsyVjRJe+v8IjiPAdpn4BCGB0l4W0oKJMDcZmJq6SjFFQm
+7pdUXDkWbhDQ4GStvpUrZRsCAwEAAQ==
 -----END rsa public key-----
--- a/docs/api/packages/eventbus.md
+++ b/docs/api/packages/eventbus.md
@@ -0,0 +1,401 @@
+# EventBus
+
+EventbBus是一个事件总线，用于在应用程序中处理事件。
+
+<div STYLE="page-break-after: always;"></div>
+
+## 源码:
+
+-   [https://github.com/duke-git/lancet/blob/main/eventbus/eventbus.go](https://github.com/duke-git/lancet/blob/main/eventbus/eventbus.go)
+
+<div STYLE="page-break-after: always;"></div>
+
+## 用法:
+
+```go
+import (
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+```
+
+<div STYLE="page-break-after: always;"></div>
+
+## 目录
+
+-   [NewEventBus](#NewEventBus)
+-   [Subscribe](#Subscribe)
+-   [Unsubscribe](#Unsubscribe)
+-   [Publish](#Publish)
+-   [ClearListeners](#ClearListeners)
+-   [ClearListenersByTopic](#ClearListenersByTopic)
+-   [GetListenersCount](#GetListenersCount)
+-   [GetAllListenersCount](#GetAllListenersCount)
+-   [GetEvents](#GetEvents)
+-   [SetErrorHandler](#SetErrorHandler)
+
+
+<div STYLE="page-break-after: always;"></div>
+
+## 文档
+
+### <span id="NewEventBus">NewEventBus</span>
+
+<p>创建EventBus实例。</p>
+
+<b>函数签名:</b>
+
+```go
+func NewEventBus[T any]() *EventBus[T]
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 1
+}
+```
+
+### <span id="Subscribe">Subscribe</span>
+
+<p>订阅具有特定事件主题和监听函数的事件。支持异步，事件优先级，事件过滤器。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) Subscribe(topic string, listener func(eventData T), async bool, priority int, filter func(eventData T) bool)
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    filter := func(eventData int) bool {
+        return eventData == 1
+    }
+
+    eb.Subscribe("event1", listener, false, 0, filter)
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+    eb.Publish(Event[int]{Topic: "event1", Payload: 2})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 1
+}
+```
+
+### <span id="Unsubscribe">Unsubscribe</span>
+
+<p>取消订阅具有特定事件主题的事件。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) Unsubscribe(topic string, listener func(eventData T))
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.Unsubscribe("event1", listener)
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 0
+}
+```
+
+### <span id="Publish">Publish</span>
+
+<p>发布一个带有特定事件主题和数据负载的事件。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) Publish(event Event[T])
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {
+        fmt.Println(eventData)
+    }, false, 0, nil)
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    // Output:
+    // 1
+}
+```
+
+### <span id="ClearListeners">ClearListeners</span>
+
+<p>清空所有事件监听器。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) ClearListeners()
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.ClearListeners()
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 0
+}
+```
+
+### <span id="ClearListenersByTopic">ClearListenersByTopic</span>
+
+<p>清空特定事件监听器。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) ClearListenersByTopic(topic string)
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.ClearListenersByTopic("event1")
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 0
+}
+```
+
+### <span id="GetListenersCount">GetListenersCount</span>
+
+<p>获取特定事件的监听器数量。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) GetListenersCount(topic string) int
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+
+    count := eb.GetListenersCount("event1")
+
+    fmt.Println(count)
+
+    // Output:
+    // 2
+}
+```
+
+### <span id="GetAllListenersCount">GetAllListenersCount</span>
+
+<p>获取所有事件的监听器数量。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) GetAllListenersCount() int
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+    eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+    count := eb.GetAllListenersCount()
+
+    fmt.Println(count)
+
+    // Output:
+    // 2
+}
+```
+
+### <span id="GetEvents">GetEvents</span>
+
+<p>获取所有事件的topic。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) GetEvents() []string
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+    eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+    events := eb.GetEvents()
+
+    for _, event := range events {
+        fmt.Println(event)
+    }
+
+    // Output:
+    // event1
+    // event2
+}
+```
+
+### <span id="SetErrorHandler">SetErrorHandler</span>
+
+<p>设置事件的错误处理函数。</p>
+
+<b>函数签名:</b>
+
+```go
+func (eb *EventBus[T]) SetErrorHandler(handler func(err error))
+```
+
+<b>示例:<span style="float:right;display:inline-block;">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.SetErrorHandler(func(err error) {
+		fmt.Println(err)
+	})
+
+	eb.Subscribe("event1", func(eventData int) {
+		panic("error")
+	}, false, 0, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	// Output:
+	// error
+}
+```
--- a/docs/api/packages/validator.md
+++ b/docs/api/packages/validator.md
@@ -49,6 +49,7 @@ import (
 -   [IsIp](#IsIp)
 -   [IsIpV4](#IsIpV4)
 -   [IsIpV6](#IsIpV6)
+-   [IsIpPort](#IsIpPort)
 -   [IsStrongPassword](#IsStrongPassword)
 -   [IsUrl](#IsUrl)
 -   [IsWeakPassword](#IsWeakPassword)
@@ -990,6 +991,43 @@ func main() {
 }
 ```

+### <span id="IsIpPort">IsIpPort</span>
+
+<p>检查字符串是否是ip:port格式。</p>
+
+<b>函数签名:</b>
+
+```go
+func IsIpPort(str string) bool
+```
+
+<b>示例:<span style="float:right;display:inline-block">[运行](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/validator"
+)
+
+func main() {
+    result1 := validator.IsIpPort("127.0.0.1:8080")
+    result2 := validator.IsIpPort("[0:0:0:0:0:0:0:1]:8080")
+    result3 := validator.IsIpPort(":8080")
+    result4 := validator.IsIpPort("::0:0:0:0:")
+
+    fmt.Println(result1)
+    fmt.Println(result2)
+    fmt.Println(result3)
+    fmt.Println(result4)
+
+    // Output:
+    // true
+    // true
+    // false
+    // false
+}
+```
+
 ### <span id="IsStrongPassword">IsStrongPassword</span>

 <p>验证字符串是否是强密码：(alpha(lower+upper) + number + special chars(!@#$%^&*()?&gt&lt))。</p>
--- a/docs/en/api/packages/eventbus.md
+++ b/docs/en/api/packages/eventbus.md
@@ -0,0 +1,401 @@
+# EventBus
+
+EventBus is an event bus used for handling events within an application.
+
+<div STYLE="page-break-after: always;"></div>
+
+## Source:
+
+-   [https://github.com/duke-git/lancet/blob/main/eventbus/eventbus.go](https://github.com/duke-git/lancet/blob/main/eventbus/eventbus.go)
+
+<div STYLE="page-break-after: always;"></div>
+
+## Usage:
+
+```go
+import (
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+```
+
+<div STYLE="page-break-after: always;"></div>
+
+## Index
+
+-   [NewEventBus](#NewEventBus)
+-   [Subscribe](#Subscribe)
+-   [Unsubscribe](#Unsubscribe)
+-   [Publish](#Publish)
+-   [ClearListeners](#ClearListeners)
+-   [ClearListenersByTopic](#ClearListenersByTopic)
+-   [GetListenersCount](#GetListenersCount)
+-   [GetAllListenersCount](#GetAllListenersCount)
+-   [GetEvents](#GetEvents)
+-   [SetErrorHandler](#SetErrorHandler)
+
+
+<div STYLE="page-break-after: always;"></div>
+
+## Documentation
+
+### <span id="NewEventBus">NewEventBus</span>
+
+<p>Create an EventBus instance.</p>
+
+<b>Signature:</b>
+
+```go
+func NewEventBus[T any]() *EventBus[T]
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 1
+}
+```
+
+### <span id="Subscribe">Subscribe</span>
+
+<p>Subscribes to an event with a specific event topic and listener function.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) Subscribe(topic string, listener func(eventData T), async bool, priority int, filter func(eventData T) bool)
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    filter := func(eventData int) bool {
+        return eventData == 1
+    }
+
+    eb.Subscribe("event1", listener, false, 0, filter)
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+    eb.Publish(Event[int]{Topic: "event1", Payload: 2})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 1
+}
+```
+
+### <span id="Unsubscribe">Unsubscribe</span>
+
+<p>Unsubscribes from an event with a specific event topic and listener function.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) Unsubscribe(topic string, listener func(eventData T))
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.Unsubscribe("event1", listener)
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 0
+}
+```
+
+### <span id="Publish">Publish</span>
+
+<p>Publishes an event with a specific event topic and data payload.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) Publish(event Event[T])
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {
+        fmt.Println(eventData)
+    }, false, 0, nil)
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    // Output:
+    // 1
+}
+```
+
+### <span id="ClearListeners">ClearListeners</span>
+
+<p>Clears all the listeners.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) ClearListeners()
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.ClearListeners()
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 0
+}
+```
+
+### <span id="ClearListenersByTopic">ClearListenersByTopic</span>
+
+<p>Clears all the listeners by topic.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) ClearListenersByTopic(topic string)
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    receivedData := 0
+    listener := func(eventData int) {
+        receivedData = eventData
+    }
+
+    eb.Subscribe("event1", listener, false, 0, nil)
+    eb.ClearListenersByTopic("event1")
+
+    eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+    fmt.Println(receivedData)
+
+    // Output:
+    // 0
+}
+```
+
+### <span id="GetListenersCount">GetListenersCount</span>
+
+<p>Returns the number of listeners for a specific event topic.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) GetListenersCount(topic string) int
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+
+    count := eb.GetListenersCount("event1")
+
+    fmt.Println(count)
+
+    // Output:
+    // 2
+}
+```
+
+### <span id="GetAllListenersCount">GetAllListenersCount</span>
+
+<p>Returns the total number of all listeners.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) GetAllListenersCount() int
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+    eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+    count := eb.GetAllListenersCount()
+
+    fmt.Println(count)
+
+    // Output:
+    // 2
+}
+```
+
+### <span id="GetEvents">GetEvents</span>
+
+<p>Returns all the events topics.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) GetEvents() []string
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+    eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+    events := eb.GetEvents()
+
+    for _, event := range events {
+        fmt.Println(event)
+    }
+
+    // Output:
+    // event1
+    // event2
+}
+```
+
+### <span id="SetErrorHandler">SetErrorHandler</span>
+
+<p>Sets the error handler function.</p>
+
+<b>Signature:</b>
+
+```go
+func (eb *EventBus[T]) SetErrorHandler(handler func(err error))
+```
+
+<b>Example:<span style="float:right;display:inline-block;">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/eventbus"
+)
+
+func main() {
+    eb := eventbus.NewEventBus[int]()
+
+    eb.SetErrorHandler(func(err error) {
+		fmt.Println(err)
+	})
+
+	eb.Subscribe("event1", func(eventData int) {
+		panic("error")
+	}, false, 0, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	// Output:
+	// error
+}
+```
--- a/docs/en/api/packages/slice.md
+++ b/docs/en/api/packages/slice.md
@@ -844,7 +844,7 @@ func main() {

 ### <span id="EqualUnordered">EqualUnordered</span>

-<p>Checks if two slices are equal: the same length and all elements' value are equal (unordered).</p>
+<p>Checks if two slices are equal: the same length and all elements value are equal (unordered).</p>

 <b>Signature:</b>

--- a/docs/en/api/packages/validator.md
+++ b/docs/en/api/packages/validator.md
@@ -49,6 +49,7 @@ import (
 -   [IsIp](#IsIp)
 -   [IsIpV4](#IsIpV4)
 -   [IsIpV6](#IsIpV6)
+-   [IsIpPort](#IsIpPort)
 -   [IsStrongPassword](#IsStrongPassword)
 -   [IsUrl](#IsUrl)
 -   [IsWeakPassword](#IsWeakPassword)
@@ -992,6 +993,43 @@ func main() {
 }
 ```

+### <span id="IsIpPort">IsIpPort</span>
+
+<p>Check if the string is ip:port</p>
+
+<b>Signature:</b>
+
+```go
+func IsIpPort(str string) bool
+```
+
+<b>Example:<span style="float:right;display:inline-block">[Run](todo)</span></b>
+
+```go
+import (
+    "fmt"
+    "github.com/duke-git/lancet/v2/validator"
+)
+
+func main() {
+    result1 := validator.IsIpPort("127.0.0.1:8080")
+	result2 := validator.IsIpPort("[0:0:0:0:0:0:0:1]:8080")
+	result3 := validator.IsIpPort(":8080")
+	result4 := validator.IsIpPort("::0:0:0:0:")
+
+	fmt.Println(result1)
+	fmt.Println(result2)
+	fmt.Println(result3)
+	fmt.Println(result4)
+
+	// Output:
+	// true
+	// true
+	// false
+	// false
+}
+```
+
 ### <span id="IsStrongPassword">IsStrongPassword</span>

 <p>Check if the string is strong password (alpha(lower+upper) + number + special chars(!@#$%^&*()?gt&lt)).</p>
--- a/eventbus/eventbus.go
+++ b/eventbus/eventbus.go
@@ -33,6 +33,7 @@ type EventListener[T any] struct {
 }

 // NewEventBus creates a new EventBus.
+// Play: todo
 func NewEventBus[T any]() *EventBus[T] {
 	return &EventBus[T]{
 		listeners: sync.Map{},
@@ -40,6 +41,7 @@ func NewEventBus[T any]() *EventBus[T] {
 }

 // Subscribe subscribes to an event with a specific event topic and listener function.
+// Play: todo
 func (eb *EventBus[T]) Subscribe(topic string, listener func(eventData T), async bool, priority int, filter func(eventData T) bool) {
 	eb.mu.Lock()
 	defer eb.mu.Unlock()
@@ -63,6 +65,7 @@ func (eb *EventBus[T]) Subscribe(topic string, listener func(eventData T), async
 }

 // Unsubscribe unsubscribes from an event with a specific event topic and listener function.
+// Play: todo
 func (eb *EventBus[T]) Unsubscribe(topic string, listener func(eventData T)) {
 	eb.mu.Lock()
 	defer eb.mu.Unlock()
@@ -86,6 +89,7 @@ func (eb *EventBus[T]) Unsubscribe(topic string, listener func(eventData T)) {
 }

 // Publish publishes an event with a specific event topic and data payload.
+// Play: todo
 func (eb *EventBus[T]) Publish(event Event[T]) {
 	eb.mu.RLock()
 	defer eb.mu.RUnlock()
@@ -126,6 +130,7 @@ func (eb *EventBus[T]) SetErrorHandler(handler func(err error)) {
 }

 // ClearListeners clears all the listeners.
+// Play: todo
 func (eb *EventBus[T]) ClearListeners() {
 	eb.mu.Lock()
 	defer eb.mu.Unlock()
@@ -134,6 +139,7 @@ func (eb *EventBus[T]) ClearListeners() {
 }

 // ClearListenersByTopic clears all the listeners by topic.
+// Play: todo
 func (eb *EventBus[T]) ClearListenersByTopic(topic string) {
 	eb.mu.Lock()
 	defer eb.mu.Unlock()
@@ -142,6 +148,7 @@ func (eb *EventBus[T]) ClearListenersByTopic(topic string) {
 }

 // GetListenersCount returns the number of listeners for a specific event topic.
+// Play: todo
 func (eb *EventBus[T]) GetListenersCount(topic string) int {
 	eb.mu.RLock()
 	defer eb.mu.RUnlock()
@@ -156,6 +163,7 @@ func (eb *EventBus[T]) GetListenersCount(topic string) int {
 }

 // GetAllListenersCount returns the total number of listeners.
+// Play: todo
 func (eb *EventBus[T]) GetAllListenersCount() int {
 	eb.mu.RLock()
 	defer eb.mu.RUnlock()
@@ -170,6 +178,7 @@ func (eb *EventBus[T]) GetAllListenersCount() int {
 }

 // GetEvents returns all the events topics.
+// Play: todo
 func (eb *EventBus[T]) GetEvents() []string {
 	eb.mu.RLock()
 	defer eb.mu.RUnlock()
--- a/eventbus/eventbus_example_test.go
+++ b/eventbus/eventbus_example_test.go
@@ -0,0 +1,229 @@
+package eventbus
+
+import (
+	"fmt"
+	"sync"
+	"time"
+)
+
+func ExampleEventBus_Subscribe() {
+	eb := NewEventBus[string]()
+	eb.Subscribe("event1", func(eventData string) {
+		fmt.Println(eventData)
+	}, false, 0, nil)
+
+	eb.Publish(Event[string]{Topic: "event1", Payload: "hello"})
+
+	// Output:
+	// hello
+}
+
+func ExampleEventBus_Unsubscribe() {
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	eb.Subscribe("event1", listener, false, 0, nil)
+	eb.Unsubscribe("event1", listener)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	fmt.Println(receivedData)
+
+	// Output:
+	// 0
+}
+
+func ExampleEventBus_Subscribe_WithFilter() {
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	filter := func(eventData int) bool {
+		return eventData == 1
+	}
+
+	eb.Subscribe("event1", listener, false, 0, filter)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+	eb.Publish(Event[int]{Topic: "event1", Payload: 2})
+
+	fmt.Println(receivedData)
+
+	// Output:
+	// 1
+}
+
+func ExampleEventBus_Subscribe_WithPriority() {
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {
+		fmt.Println(eventData)
+	}, false, 0, nil)
+
+	eb.Subscribe("event1", func(eventData int) {
+		fmt.Println(eventData)
+	}, false, 1, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	// Output:
+	// 1
+	// 1
+}
+
+func ExampleEventBus_Subscribe_Async() {
+	eb := NewEventBus[int]()
+
+	var wg sync.WaitGroup
+	wg.Add(1)
+
+	eb.Subscribe("event1", func(eventData int) {
+		time.Sleep(100 * time.Millisecond)
+		fmt.Println(eventData)
+		wg.Done()
+	}, true, 1, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+	wg.Wait()
+
+	// Output:
+	// 1
+}
+
+func ExampleEventBus_Publish() {
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {
+		fmt.Println(eventData)
+	}, false, 0, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	// Output:
+	// 1
+}
+
+func ExampleEventBus() {
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	eb.Subscribe("event1", listener, false, 0, nil)
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	fmt.Println(receivedData)
+
+	// Output:
+	// 1
+}
+
+func ExampleEventBus_ClearListeners() {
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	eb.Subscribe("event1", listener, false, 0, nil)
+	eb.ClearListeners()
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	fmt.Println(receivedData)
+
+	// Output:
+	// 0
+}
+
+func ExampleEventBus_ClearListenersByTopic() {
+	eb := NewEventBus[int]()
+
+	receivedData := 0
+	listener := func(eventData int) {
+		receivedData = eventData
+	}
+
+	eb.Subscribe("event1", listener, false, 0, nil)
+	eb.ClearListenersByTopic("event1")
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	fmt.Println(receivedData)
+
+	// Output:
+	// 0
+}
+
+func ExampleEventBus_GetListenersCount() {
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+
+	count := eb.GetListenersCount("event1")
+
+	fmt.Println(count)
+
+	// Output:
+	// 2
+}
+
+func ExampleEventBus_SetErrorHandler() {
+	eb := NewEventBus[int]()
+
+	eb.SetErrorHandler(func(err error) {
+		fmt.Println(err)
+	})
+
+	eb.Subscribe("event1", func(eventData int) {
+		panic("error")
+	}, false, 0, nil)
+
+	eb.Publish(Event[int]{Topic: "event1", Payload: 1})
+
+	// Output:
+	// error
+}
+
+func ExampleEventBus_GetAllListenersCount() {
+
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+	count := eb.GetAllListenersCount()
+
+	fmt.Println(count)
+
+	// Output:
+	// 2
+}
+
+func ExampleEventBus_GetEvents() {
+	eb := NewEventBus[int]()
+
+	eb.Subscribe("event1", func(eventData int) {}, false, 0, nil)
+	eb.Subscribe("event2", func(eventData int) {}, false, 0, nil)
+
+	events := eb.GetEvents()
+
+	for _, event := range events {
+		fmt.Println(event)
+	}
+
+	// Output:
+	// event1
+	// event2
+}
Author	SHA1	Message	Date
dudaodong	29a8318d6e	doc: update for release v2.3.5	2025-03-06 20:11:21 +08:00
dudaodong	3696213e5d	doc: update for release v2.3.5	2025-03-06 20:02:33 +08:00
dudaodong	90a3b87b67	doc: add doc for eventbus package	2025-03-06 15:50:12 +08:00