锐客网

  1. 首页 > 睿知 > it技术 > >

java即时消息源代码 java如何实现实时消息推送( 二 )

IT技术消息


//将发送内容放置文本域里
tarea.insert("\r\n\n发至:"+dp1.getAddress().getHostAddress()+" 时间:"+
time.toLocaleString()+"\n"+tfield1.getText()+"\n",len);//将文本框中内容插入指定位置
tfield1.setText(""); //清空文本框
}
/**
*实现Runnable接口的run方法
*/
public void run()
{
while(true)
{
try
{
Thread.currentThread().sleep(600);//线程暂停0.6秒
s=Receives();
if(s.length()0)
{
tarea.setText(tarea.getText()+"\n"+s);
}
}catch(Exception ie)
{
ie.printStackTrace();
}
}
}
//接收信息的方法
public String Receives() throws Exception
{
ds2=new DatagramSocket(5000);
byte[] buf=new byte[1024];
dp2=new DatagramPacket(buf,1024);
ds2.receive(dp2);
String s="来自:"+dp2.getAddress()+" 时间:"+new Date().toLocaleString()
+"\n"+new String(dp2.getData(),0,dp2.getLength());
ds2.close();
return s;
}
/**
*主函数
*/
public static void main(String[] args)
{
Chat c=new Chat();
}
}
//这是java的原代码 拿过去编译下就可以用java即时消息源代码了
如何用JAVA实现Linux上的消息队列功能下面来说说如何用不用消息队列来进行进程间的通信，消息队列与命名管道有很多相似之处 。有关命名管道的更多内容可以参阅我的另一篇文章：Linux进程间通信——使用命名管道
一、什么是消息队列
消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法 。每个数据块都被认为含有一个类型，接收进程可以独立地接收含有不同类型的数据结构 。我们可以通过发送消息来避免命名管道的同步和阻塞问题 。但是消息队列与命名管道一样，每个数据块都有一个最大长度的限制 。
Linux用宏MSGMAX和MSGMNB来限制一条消息的最大长度和一个队列的最大长度 。
二、在Linux中使用消息队列
Linux提供了一系列消息队列的函数接口来让我们方便地使用它来实现进程间的通信 。它的用法与其他两个System V PIC机制，即信号量和共享内存相似 。
1、msgget函数
该函数用来创建和访问一个消息队列 。它的原型为：
int msgget(key_t, key, int msgflg);
与其他的IPC机制一样，程序必须提供一个键来命名某个特定的消息队列 。msgflg是一个权限标志，表示消息队列的访问权限，它与文件的访问权限一样 。msgflg可以与IPC_CREAT做或操作，表示当key所命名的消息队列不存在时创建一个消息队列 ， 如果key所命名的消息队列存在时，IPC_CREAT标志会被忽略，而只返回一个标识符 。
它返回一个以key命名的消息队列的标识符（非零整数），失败时返回-1.
2、msgsnd函数
该函数用来把消息添加到消息队列中 。它的原型为：
int msgsend(int msgid, const void *msg_ptr, size_t msg_sz, int msgflg);
msgid是由msgget函数返回的消息队列标识符 。
msg_ptr是一个指向准备发送消息的指针，但是消息的数据结构却有一定的要求，指针msg_ptr所指向的消息结构一定要是以一个长整型成员变量开始的结构体 ， 接收函数将用这个成员来确定消息的类型 。所以消息结构要定义成这样：
struct my_message{
long int message_type;
/* The data you wish to transfer*/
};
msg_sz是msg_ptr指向的消息的长度 ， 注意是消息的长度，而不是整个结构体的长度，也就是说msg_sz是不包括长整型消息类型成员变量的长度 。
msgflg用于控制当前消息队列满或队列消息到达系统范围的限制时将要发生的事情 。
如果调用成功，消息数据的一分副本将被放到消息队列中，并返回0，失败时返回-1.

推荐阅读


上一篇：小米电视3安卓软件怎么用，小米电视三方软件在哪

下一篇：直播话术瑜伽裤，搜索瑜伽直播