类的使用
org.redkale.service.Local

使用Local的程序包

程序包	说明
org.redkale.cached.spi
org.redkale.locked.spi
org.redkale.mq	MQ服务包
org.redkale.net.http	HTTP协议包,提供HTTP协议服务器
org.redkale.scheduled.spi
org.redkale.source	数据源(数据库、缓存)操作包

org.redkale.cached.spi中Local的使用

注释类型为Local的org.redkale.cached.spi中的类

修饰符和类型	类	说明
class	CachedManagerService	缓存管理器

org.redkale.locked.spi中Local的使用

注释类型为Local的org.redkale.locked.spi中的类

修饰符和类型	类	说明
class	LockedManagerService

org.redkale.mq中Local的使用

注释类型为Local的org.redkale.mq中的类

修饰符和类型	接口	说明
interface	MessageConsumer<T>	MQ消费器， 实现类必须标记ResourceConsumer

org.redkale.net.http中Local的使用

注释类型为Local的org.redkale.net.http中的方法

修饰符和类型	方法	说明
CompletableFuture<Integer>	WebSocketNode.broadcastAction(WebSocketAction action)	广播操作， 给所有人发操作
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(Object message)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(Object message, boolean last)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(Convert convert, Object message)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(Convert convert, Object message0, boolean last)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(WebSocketRange wsrange, Object message)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(WebSocketRange wsrange, Object message, boolean last)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(WebSocketRange wsrange, Convert convert, Object message)	广播消息， 给所有人发消息
CompletableFuture<Integer>	WebSocketNode.broadcastMessage(WebSocketRange wsrange, Convert convert, Object message0, boolean last)	广播消息， 给所有人发消息
CompletableFuture<Boolean>	WebSocketNode.existsWebSocket(Serializable userid)	判断指定用户是否WebSocket在线
CompletableFuture<Boolean>	WebSocketNode.existsWebSocket(WebSocketUserAddress userAddress)	判断指定用户是否WebSocket在线
CompletableFuture<Integer>	WebSocketNode.forceCloseWebSocket(Serializable userid)	强制关闭用户WebSocket
CompletableFuture<Integer>	WebSocketNode.forceCloseWebSocket(WebSocketUserAddress userAddress)	强制关闭用户WebSocket
WebSocketEngine	WebSocketNode.getLocalWebSocketEngine()	获取本地的WebSocketEngine，没有则返回null
MessageAgent	WebSocketNode.getMessageAgent()
Semaphore	WebSocketNode.getSemaphore()
CompletableFuture<Integer>	WebSocketNode.getUserSize()	获取在线用户总数
protected void	WebSocketNode.postDestroy(AnyValue conf)
CompletableFuture<Integer>	WebSocketNode.sendAction(WebSocketAction action, Serializable... userids)	向指定用户发送操作，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendAction(WebSocketAction action, WebSocketUserAddress... useraddrs)	向指定用户发送操作，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Object message, boolean last, Serializable... useridOrAddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Object message, boolean last, Stream<? extends Serializable> useridOrAddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Object message, Serializable... useridOrAddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Object message, Stream<? extends Serializable> useridOrAddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Convert convert, Object message0, boolean last, Serializable... userids)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Convert convert, Object message0, boolean last, Stream<? extends Serializable> userids)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Convert convert, Object message0, boolean last, WebSocketUserAddress... useraddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Convert convert, Object message, Serializable... useridOrAddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接
CompletableFuture<Integer>	WebSocketNode.sendMessage(Convert convert, Object message, Stream<? extends Serializable> useridOrAddrs)	向指定用户发送消息，先发送本地连接，再发送远程连接 如果当前WebSocketNode是远程模式，此方法只发送远程连接

org.redkale.scheduled.spi中Local的使用

注释类型为Local的org.redkale.scheduled.spi中的类

修饰符和类型	类	说明
class	ScheduleManagerService	定时任务管理器

org.redkale.source中Local的使用

注释类型为Local的org.redkale.source中的类

修饰符和类型	类	说明
class	AbstractCacheSource	CacheSource的S抽象实现类 详情见: https://redkale.org
class	AbstractDataSource	DataSource的S抽象实现类 注意: 所有的操作只能作用在一张表上，不能同时变更多张表
class	AbstractDataSqlSource	DataSource的SQL抽象实现类 注意: 所有的操作只能作用在一张表上，不能同时变更多张表
class	CacheMemorySource	CacheSource的默认实现--内存缓存 注意: url 需要指定为 memory:cachesource
class	DataJdbcSource	DataSource的JDBC实现类
class	DataMemorySource	DataSource的Memory实现类 注意: url 需要指定为 memory:datasource

注释类型为Local的org.redkale.source中的方法

修饰符和类型	方法	说明
<T> void	DataMemorySource.compile(Class<T> clazz)
DataJdbcConnection	DataJdbcSource.getReadJdbcConnection()
String	DataMemorySource.getType()
DataJdbcConnection	DataJdbcSource.getWriteJdbcConnection()
<V> V	DataJdbcSource.nativeQuery(String sql, BiConsumer<Object,Object> consumer, Function<DataResultSet,V> handler)	直接本地执行SQL语句进行查询，远程模式不可用 通常用于复杂的关联查询
<V> V	DataJdbcSource.nativeQuery(String sql, BiConsumer<Object,Object> consumer, Function<DataResultSet,V> handler, Map<String,Object> params)
int	DataJdbcSource.nativeUpdate(String sql)	直接本地执行SQL语句进行增删改操作，远程模式不可用 通常用于复杂的更新操作
int	DataJdbcSource.nativeUpdate(String sql, Map<String,Object> params)
int[]	DataJdbcSource.nativeUpdates(String... sqls)	直接本地执行SQL语句进行增删改操作，远程模式不可用 通常用于复杂的更新操作
void	DataJdbcSource.offerJdbcConnection(DataJdbcConnection conn)