服务器如何及时通知客户端

客户 0 82

服务器如何及时通知客户端,第1张

服务器如何及时通知客户端
导读:如何实现服务器向客户端发出一条通知?当向服务器数据库插入一条数据时,服务器就向客户端发出一条信息,让客户端及时知道;如何实现呢?能描述清楚点吗?问题太大概了吧。向客户发送消息的sendMessage方法是不是已经准备好了?那接下来就是选择在

如何实现服务器向客户端发出一条通知?

当向服务器数据库插入一条数据时,服务器就向客户端发出一条信息,让客户端及时知道;

如何实现呢?

能描述清楚点吗?问题太大概了吧。

向客户发送消息的sendMessage方法是不是已经准备好了?

那接下来就是选择在程序中100%确定已经向数据库插入了数据的地方调用sendMessage方法。

简单的实现可以用js的alert方法。

执行数据库插入操作,后返回值,js判断,根据返回的值,如果插入成功,则alert('插入成功')

ejb的拦截器应该能实现,给向数据库插入数据的这个方法加个拦截器,在这个拦截器类里边先调用这个方法,然后实现向客户端发消息

得看你做B/S还是C/S

看不懂说的啥。。

在消息库里插一条 消息数据。 再查询出来 不就好了。 这是简单的方式咯。 复杂点就用推送技术吧

基本上就两招:

要么是 短连接下的客户端发起轮询 模型;

要么是 长连接下的服务器端主动推送 模型。

C/S没玩过,B/S用过推模式,比轮询要好的多

我现在用的数据库连接字符串是private static string conStr = @"Data Source=192168137,1611;Initial Catalog=QLYM;User ID=sa;Pwd=system";这是局域网的!那连接服务器数据库应该什么写呢?

当服务器数据库数据有更新时,客户端如何及时知道?客户端是client的,轮询会对服务器有压力,有什么技术更好的?

客户端只设置两个,每分钟访问服务器一次,这样服务器的压力应该不大吧?

服务器端源码:\x0d\import javaioBufferedReader;\x0d\import javaioFile;\x0d\import javaioFileNotFoundException;\x0d\import javaioFileOutputStream;\x0d\import javaioIOException;\x0d\import javaioInputStream;\x0d\import javaioInputStreamReader;\x0d\import javanetServerSocket;\x0d\import javanetSocket;\x0d\\x0d\/\x0d\ \x0d\ 文件名:ServerReceivejava\x0d\ 实现功能:作为服务器接收客户端发送的文件\x0d\ \x0d\ 具体实现过程:\x0d\ 1、建立SocketServer,等待客户端的连接\x0d\ 2、当有客户端连接的时候,按照双方的约定,这时要读取一行数据\x0d\ 其中保存客户端要发送的文件名和文件大小信息\x0d\ 3、根据文件名在本地创建文件,并建立好流通信\x0d\ 4、循环接收数据包,将数据包写入文件\x0d\ 5、当接收数据的长度等于提前文件发过来的文件长度,即表示文件接收完毕,关闭文件\x0d\ 6、文件接收工作结束\x0d\\x0d\public class ServerReceive {\x0d\ \x0d\ public static void main(String[] args) {\x0d\ \x0d\ /与服务器建立连接的通信句柄/\x0d\ ServerSocket ss = null;\x0d\ Socket s = null;\x0d\ \x0d\ /定义用于在接收后在本地创建的文件对象和文件输出流对象/\x0d\ File file = null;\x0d\ FileOutputStream fos = null;\x0d\ \x0d\ /定义输入流,使用socket的inputStream对数据包进行输入/\x0d\ InputStream is = null;\x0d\ \x0d\ /定义byte数组来作为数据包的存储数据包/\x0d\ byte[] buffer = new byte[4096 5];\x0d\ \x0d\ /用来接收文件发送请求的字符串/\x0d\ String comm = null;\x0d\\x0d\/建立socekt通信,等待服务器进行连接/\x0d\ try {\x0d\ ss = new ServerSocket(4004);\x0d\ s = ssaccept();\x0d\ } catch (IOException e) {\x0d\ eprintStackTrace();\x0d\ }\x0d\\x0d\/读取一行客户端发送过来的约定信息/\x0d\ try {\x0d\ InputStreamReader isr = new InputStreamReader(sgetInputStream());\x0d\ BufferedReader br = new BufferedReader(isr);\x0d\ comm = brreadLine();\x0d\ } catch (IOException e) {\x0d\ Systemoutprintln("服务器与客户端断开连接");\x0d\ }\x0d\ \x0d\ /开始解析客户端发送过来的请求命令/\x0d\ int index = commindexOf("/#");\x0d\ \x0d\ /判断协议是否为发送文件的协议/\x0d\ String xieyi = commsubstring(0, index);\x0d\ if(!xieyiequals("111")){\x0d\ Systemoutprintln("服务器收到的协议码不正确");\x0d\ return;\x0d\ }\x0d\ \x0d\ /解析出文件的名字和大小/\x0d\ comm = commsubstring(index + 2);\x0d\ index = commindexOf("/#");\x0d\ String filename = commsubstring(0, index)trim();\x0d\ String filesize = commsubstring(index + 2)trim();\x0d\\x0d\/创建空文件,用来进行接收文件/\x0d\ file = new File(filename);\x0d\ if(!fileexists()){\x0d\ try {\x0d\ filecreateNewFile();\x0d\ } catch (IOException e) {\x0d\ Systemoutprintln("服务器端创建文件失败");\x0d\ }\x0d\ }else{\x0d\ /在此也可以询问是否覆盖/\x0d\ Systemoutprintln("本路径已存在相同文件,进行覆盖");\x0d\ }\x0d\ \x0d\ /以上就是客户端代码中写到的服务器的准备部分/\x0d\\x0d\/\x0d\ 服务器接收文件的关键代码/\x0d\ try {\x0d\ /将文件包装到文件输出流对象中/\x0d\ fos = new FileOutputStream(file);\x0d\ long file_size = LongparseLong(filesize);\x0d\ is = sgetInputStream();\x0d\ /size为每次接收数据包的长度/\x0d\ int size = 0;\x0d\ /count用来记录已接收到文件的长度/\x0d\ long count = 0;\x0d\ \x0d\ /使用while循环接收数据包/\x0d\ while(count