锐客网

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

消息队列java代码 java消息队列应用场景

IT技术消息

到底什么是消息队列？Java中如何实现消息队列消息队列，顾名思义
首先是个队列 。
队列的操作有入队和出队
也就是你有一个程序在产生内容然后入队（生产者）
另一个程序读取内容，内容出队（消费者）
这是最最基本的概念 。
我想你应该是缺乏一个使用场景 。
当你不需要立即获得结果，但是并发量又不能无限大的时候 ， 差不多就是你需要使用消息队列的时候 。
比如你写日志，因为可能一个客户端有多个操作去写，又有很多个客户端，显然并发不能无穷大 ， 于是你就需要把写日志的请求放入到消息队列里，在消费者那边依次把队列中产生的日志写到数据库里 。
至于怎么实现消息队列，其实你本身一个普通的队列就行呀~看你需要什么附加功能而已 。
用java代码怎样将报文A生成报文的某个值传递给报文B中的某个字段看 Oracle 官方教程，同步式的 Socket 就是传统的一问一答方式，它就是你需要的 。
客户端先 socket.getOutputStream().write(...); 之后到 socket.getInputStream().read(byte[]) 在循环中读取直到 read 方法返回 -1 或你期望的字节数已经全部收到了就停下来 ， 如果不尝试停下来 ， 后面的 read 将会阻塞等待 。
基于性能改进，一般我们需要使用 NIO 异步的 socket，只需要一个线程负责通信，每个线程都有自己的出站消息队列和入站消息队列，以线程为 key 区分开 ， 通信线程只负责把各自的消息从出站队列中发送去并把收到的消息放入入站队列中，应用程序线程就去各自的消息队列中取消息就可以了 。因为每个应用线程有各自的消息队列，我们把消息放入出站队列之后就到入站队列上用同步锁等待的方法阻塞到有消息回答时为止 。
关于 NIO non-blocking 非阻塞式 socket，下面有一个 NBTimeServer 例子，它讲的是服务端 。客户端与此类似，
如何用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函数
【消息队列java代码 java消息队列应用场景】该函数用来把消息添加到消息队列中 。它的原型为：

推荐阅读


上一篇：电视怎么屏蔽机顶盒频道，电视怎么屏蔽机顶盒频道广告

下一篇：直播有趣绘画素材下载，直播画稿