JAVA通信编程(四)——UDP通讯

简介: 经过TCP和串口通讯编程的了解,相信大家应该掌握CommBuff的套路了,这里首先展示的是通过UDP编程的方式实现CommBuff接口,之后通过简单工厂模式的应用说明如何屏蔽底层通讯差异。 UdpImpl类如下: package com.

经过TCP和串口通讯编程的了解,相信大家应该掌握CommBuff的套路了,这里首先展示的是通过UDP编程的方式实现CommBuff接口,之后通过简单工厂模式的应用说明如何屏蔽底层通讯差异。

UdpImpl类如下:

package com.zzh.comm;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Map;

import org.apache.log4j.Logger;

public class UdpImpl implements CommBuff
{
	private Logger logger = Logger.getLogger(Object.class.getName());
	
	private int local_port;
	private int dest_port;
	private String ip;
	private int time_out;
	
	DatagramSocket client = null;
	
	private String fileName = "/udp.properties";
	public UdpImpl()
	{
		Map<String,String> map = new ReadProperties().getPropertiesMap(fileName);
		try
		{
			local_port = Integer.parseInt(map.get("udp_local_port"));
			dest_port = Integer.parseInt(map.get("udp_dest_port"));
			time_out = Integer.parseInt(map.get("udp_timeout"));
			ip = map.get("udp_dest_ip");
		}
		catch (Exception e)
		{
			logger.error(e.getMessage());
		}
	}
	
	@Override
	public byte[] readBuff()
	{
		if(client == null)
		{
			throw new RuntimeException("clinet is null!");
		}
		byte[] recvBuf = new byte[1024];
		DatagramPacket recvPacket = new DatagramPacket(recvBuf , recvBuf.length);
		try
		{
			client.receive(recvPacket);
		}
		catch (IOException e)
		{
			logger.info(e.getMessage());
			return new byte[0];
		}
		byte[] ans = new byte[recvPacket.getLength()];
		System.arraycopy(recvPacket.getData(), 0, ans, 0, recvPacket.getLength());
		logger.info("网口接收:"+CommUtil.bytesToHex(ans));
		return ans;
	}

	@Override
	public void writeBuff(byte[] message)
	{
		if(client == null)
		{
			throw new RuntimeException("clinet is null!");
		}
		
		try
		{
			InetAddress addr = InetAddress.getByName(ip);
			DatagramPacket sendPacket = new DatagramPacket(message,message.length,addr,dest_port);
			client.send(sendPacket);
			logger.info("发送成功: "+CommUtil.bytesToHex(message));
		}
		catch (UnknownHostException e)
		{
			logger.error(e.getMessage());
		}
		catch (IOException e)
		{
			logger.error(e.getMessage());
		}
		
	}

	@Override
	public void open() {
		try
		{
			client = new DatagramSocket(local_port);
			client.setSoTimeout(time_out);
			if(client != null)
			{
				logger.info("client open succeed!");
			}
		}
		catch (SocketException e)
		{
			logger.error(e.getMessage());
		}
	}

	@Override
	public void close() 
	{
		if(client != null)
		{
			client.close();
		}
	}

	@Override
	public Object getInfo()
	{
		return null;
	}

}
UdpImpl实现了CommBuff接口的各个方法。UDP Socket采用的数据包的方式进行通讯的,这个可以与TCP的方式区分开。

下面通过一个简单工厂模式,可以实现底层通讯的便利性。

package com.zzh.comm;

public class CommFactory
{
	public CommBuff getCommBuff(String properties) throws Exception
	{
		if(properties.equals("comm_serial"))
		{
			return new SerialImpl();
		}
		else if(properties.equals("comm_tcpServer"))
		{
			return new TcpServerImpl();
		}
		else if(properties.equals("comm_tcpClient"))
		{
			return new TcpClientImpl();
		}
		else if(properties.equals("comm_udp"))
		{
			return new UdpImpl();
		}
		else
		{
			throw new Exception("Communication para error: no found avaliable communication Object instance.");
		}
	}
}
上面的getCommBuff方法通过参数properties可以初始化不同的通讯接口实现类,这样上次应用只需调用Commbuff接口的方法,而无需与底层通讯的细节相融合,极大的降低了程序间的耦合性。

本篇就简单的阐述到这里。但是下面会附加一个程序,这个程序通过调用CommFactory的方法生成底层通讯的实例,程序的主要内容是电力行业的某个通讯规约(Modbus)的实现,如果非电力行业的通讯,可以不必了解程序中的细节,可以大概看一下怎么使用.

package com.zzh.protocol;

import java.util.Calendar;
import java.util.Map;
import java.util.concurrent.ConcurrentLinkedDeque;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import com.zzh.comm.CommBuff;
import com.zzh.comm.CommFactory;
import com.zzh.comm.CommUtil;
import com.zzh.comm.ReadProperties;
import com.zzh.dao.ModbusDao;
import com.zzh.dao.ModbusDaoImpl;
import com.zzh.dao.pojo.ModbusPojo;

public class Modbus {
	private CommBuff comm;
	private int comm_timeout;
	private byte devAddr;
	
	private static int RECV_SIZE = 35;
	private static int RECV_INNER_SIZE = 30;
	private static int MINUTE=60000;
	private volatile boolean  refreshFlag = false;
	
	private ModbusPojo modbusPojo; 
	
	private ConcurrentLinkedDeque<Byte> deque = new ConcurrentLinkedDeque<Byte>();
	private String fileName = "/modbus.properties";
	
	public Modbus()
	{
		Map<String,String> map = new ReadProperties().getPropertiesMap(fileName);
		String comm_way = map.get("modbus_comm_way");
		String comm_timeouts = map.get("comm_timeout");
		comm_timeout = Integer.parseInt(comm_timeouts);
		String devAddrs = map.get("devAddr");
		devAddr = Byte.parseByte(devAddrs);
		if(comm_way!=null)
		{
			modbusPojo = new ModbusPojo(); 
			try
			{
				comm = new CommFactory().getCommBuff(comm_way);
			}
			catch (Exception e)
			{
				e.printStackTrace();
			}
			comm.open();
			
			ExecutorService pool = Executors.newFixedThreadPool(2);
			Thread thread1 = new Thread(new readThread());
	    	thread1.setDaemon(true);
	    	Thread thread2 = new Thread(new dbThread());
	    	thread2.setDaemon(true);
	    	pool.execute(thread1);
	    	pool.execute(thread2);
		}
		else
		{
			throw new RuntimeException("没有配置好合适的串口参数");
		}
	}
	
	private class readThread implements Runnable
	{
		@Override
		public void run()
		{
			while(true)
			{
				byte[] recvBuff = comm.readBuff();
				if(recvBuff.length>0)
				{
					for(int i=0;i<recvBuff.length;i++)
					{
						deque.add(recvBuff[i]);
					}
				}
				try
				{
					TimeUnit.MILLISECONDS.sleep(1000);
				}
				catch (InterruptedException e)
				{
					e.printStackTrace();
				}
			}
		}
	}
	
	private class dbThread implements Runnable
	{
		@Override
		public void run()
		{
			while(true)
			{
				if(refreshFlag == true)
				{
					Calendar now = Calendar.getInstance();
					if(now.get(Calendar.MINUTE)%5==0)
//					if(true)
					{
						synchronized (modbusPojo)
						{
							filterModbusPojo();
							modbusPojo.setNow(TimeUtil.getDateOfMM(now));
//							modbusPojo.setNow(new java.sql.Timestamp(new Date().getTime()));
							ModbusDao md = new ModbusDaoImpl();
							md.addModbus(modbusPojo);
						}
					}
				}
				try
				{
					TimeUnit.MILLISECONDS.sleep(MINUTE);
//					TimeUnit.MILLISECONDS.sleep(1000);
				}
				catch (InterruptedException e)
				{
					e.printStackTrace();
				}
			}
		}
		
	}
	
	public void filterModbusPojo()
	{
		modbusPojo.setQua(0);
		if(modbusPojo.getEnvTemperature()>ModbusUtil.TEMPERATURE_UP)
		{
			modbusPojo.setEnvTemperature(ModbusUtil.TEMPERATURE_UP);
			System.out.println("getEnvTemperature = "+modbusPojo.getEnvTemperature());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getEnvTemperature()<ModbusUtil.TEMPERATURE_LOW)
		{
			modbusPojo.setEnvTemperature(ModbusUtil.TEMPERATURE_LOW);
			System.out.println("getEnvTemperature = "+modbusPojo.getEnvTemperature());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getTemperature()>ModbusUtil.TEMPERATURE_UP)
		{
			modbusPojo.setTemperature(ModbusUtil.TEMPERATURE_UP);
			System.out.println("getTemperature = "+modbusPojo.getTemperature());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getTemperature()<ModbusUtil.TEMPERATURE_LOW)
		{
			modbusPojo.setTemperature(ModbusUtil.TEMPERATURE_LOW);
			System.out.println("getTemperature = "+modbusPojo.getTemperature());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getHumidity()>ModbusUtil.HUMIDITY_UP)
		{
			modbusPojo.setHumidity(ModbusUtil.HUMIDITY_UP);
			System.out.println("getHumidity = "+modbusPojo.getHumidity());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getHumidity()<ModbusUtil.HUMIDITY_LOW)
		{
			modbusPojo.setHumidity(ModbusUtil.HUMIDITY_LOW);
			System.out.println("getHumidity = "+modbusPojo.getHumidity());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getPressure()>ModbusUtil.PRESSURE_UP)
		{
			modbusPojo.setPressure(ModbusUtil.PRESSURE_UP);
			System.out.println("getPressure = "+modbusPojo.getPressure());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getPressure()<ModbusUtil.PRESSURE_LOW)
		{
			modbusPojo.setPressure(ModbusUtil.PRESSURE_LOW);
			System.out.println("getPressure = "+modbusPojo.getPressure());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getIrradiance()>ModbusUtil.IRRADIANCE_UP)
		{
			modbusPojo.setIrradiance(ModbusUtil.IRRADIANCE_UP);
			System.out.println("getIrradiance = "+modbusPojo.getIrradiance());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getIrradiance()<ModbusUtil.IRRADIANCE_LOW)
		{
			modbusPojo.setIrradiance(ModbusUtil.IRRADIANCE_LOW);
			System.out.println("getIrradiance = "+modbusPojo.getIrradiance());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getScaIrradiance()>ModbusUtil.IRRADIANCE_UP)
		{
			modbusPojo.setScaIrradiance(ModbusUtil.IRRADIANCE_UP);
			System.out.println("getScaIrradiance = "+modbusPojo.getScaIrradiance());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getScaIrradiance()<ModbusUtil.IRRADIANCE_LOW)
		{
			modbusPojo.setScaIrradiance(ModbusUtil.IRRADIANCE_LOW);
			System.out.println("getScaIrradiance = "+modbusPojo.getScaIrradiance());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getDirIrradiance()>ModbusUtil.IRRADIANCE_UP)
		{
			modbusPojo.setDirIrradiance(ModbusUtil.IRRADIANCE_UP);
			System.out.println("getDirIrradiance = "+modbusPojo.getDirIrradiance());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getDirIrradiance()<ModbusUtil.IRRADIANCE_LOW)
		{
			modbusPojo.setDirIrradiance(ModbusUtil.IRRADIANCE_LOW);
			System.out.println("getDirIrradiance = "+modbusPojo.getDirIrradiance());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getWindSpeed()>ModbusUtil.UAVG_UP)
		{
			modbusPojo.setWindSpeed(ModbusUtil.UAVG_UP);
			System.out.println("getWindSpeed = "+modbusPojo.getWindSpeed());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getWindSpeed()<ModbusUtil.UAVG_LOW)
		{
			modbusPojo.setWindSpeed(ModbusUtil.UAVG_LOW);
			System.out.println("getWindSpeed = "+modbusPojo.getWindSpeed());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getWindDir()>ModbusUtil.VAVG_UP)
		{
			modbusPojo.setWindDir(ModbusUtil.VAVG_UP);
			System.out.println("getWindDir = "+modbusPojo.getWindDir());
			modbusPojo.setQua(1);
		}
		if(modbusPojo.getWindDir()<ModbusUtil.VAVG_LOW)
		{
			modbusPojo.setWindDir(ModbusUtil.VAVG_LOW);
			System.out.println("getWindDir = "+modbusPojo.getWindDir());
			modbusPojo.setQua(1);
		}
	}
	
	public void process()
	{
		try
		{
			TimeUnit.MILLISECONDS.sleep(comm_timeout);
		}
		catch (InterruptedException e)
		{
			e.printStackTrace();
		}
		recvProcess();
		sendProcess();
	}

	public void recvProcess()
	{
		refreshFlag = false;
		byte[] recvBuff = new byte[RECV_INNER_SIZE];
		while(deque.size()>=RECV_SIZE)
		{
			Byte first = deque.pollFirst();
			if(first == devAddr)
			{
				Byte second = deque.pollFirst();
				if(second == 0x03)
				{
					Byte third = deque.pollFirst();
					if(third == RECV_INNER_SIZE)
					{
						for(int i=0;i<RECV_INNER_SIZE;i++)
						{
							recvBuff[i] = deque.pollFirst();
						}
						deque.pollFirst();
						deque.pollFirst();
						dealRecvBuff(recvBuff);
					}
				}
			}
		}
	}
	
	public void dealRecvBuff(byte[] recvBuff)
	{
		System.out.println(CommUtil.bytesToHex(recvBuff));
		refreshFlag = true;
		getModbusPojo(recvBuff);
//		modbusPojo.print();
	}
	
	public void getModbusPojo(byte[] recvBuff)
	{
		int temp;
		synchronized (modbusPojo)
		{
			for(int i=0;i<recvBuff.length;)
			{
				switch(i)
				{
					case 0:
						temp = ModbusUtil.getSignedAns(recvBuff, 0, 1);
						double envTemperature = temp*0.1;
						modbusPojo.setEnvTemperature(envTemperature);
						break;
					case 2:
						temp = ModbusUtil.getSignedAns(recvBuff, 2, 3);
						double temperature = temp*0.1;
						modbusPojo.setTemperature(temperature);
						break;
					case 4:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 4, 5);
						double humidity = temp*0.1;
						modbusPojo.setHumidity(humidity);
						break;
					case 6:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 6, 7);
						double pressure = temp*0.1;
						modbusPojo.setPressure(pressure);
						break;
					case 8:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 8, 9);
						modbusPojo.setIrradiance(temp);
						break;
					case 10:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 10, 11);
						modbusPojo.setScaIrradiance(temp);
						break;
					case 12:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 12, 13);
						modbusPojo.setDirIrradiance(temp);
						break;
					case 14:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 14, 15);
						modbusPojo.setWindDir(temp);
						break;
					case 16:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 16, 17);
						double windSpeed = temp*0.1;
						modbusPojo.setWindSpeed(windSpeed);
						break;
					case 18:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 18, 19);
						double windSpeedTwo = temp*0.1;
						modbusPojo.setWindSpeedTwo(windSpeedTwo);
						break;
					case 20:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 20, 21);
						double windSpeedTen = temp*0.1;
						modbusPojo.setWindSpeedTen(windSpeedTen);
						break;
					case 22:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 22, 23);
						modbusPojo.setDailyExposure(temp);
						break;
					case 24:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 24, 25);
						double totalExposure = temp*0.001;
						modbusPojo.setTotalExposure(totalExposure);
						break;
					case 26:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 26, 27);
						double scaExposure = temp*0.001;
						modbusPojo.setScaExposure(scaExposure);
						break;
					case 28:
						temp = ModbusUtil.getUnsignedAns(recvBuff, 28, 29);
						double dirExposure = temp*0.001;
						modbusPojo.setDirExposure(dirExposure);
						break;
				}
				i=i+2;
			}
		}
	}
	
	public void sendProcess()
	{
		byte[] message = new byte[8];
		int sendLen = 0;
		message[sendLen++] = devAddr;
		message[sendLen++] = 0x03;
		message[sendLen++] = 0x00;
		message[sendLen++] = 0x00;
		message[sendLen++] = 0x00;
		message[sendLen++] = 0x0F;
		byte[] crc = CommUtil.CRC16(message,6);
		message[sendLen++] = crc[0];
		message[sendLen++] = crc[1];
		comm.writeBuff(message);
	}

}


目录
相关文章
|
14天前
|
Java 程序员
Java编程中的异常处理:从基础到高级
在Java的世界中,异常处理是代码健壮性的守护神。本文将带你从异常的基本概念出发,逐步深入到高级用法,探索如何优雅地处理程序中的错误和异常情况。通过实际案例,我们将一起学习如何编写更可靠、更易于维护的Java代码。准备好了吗?让我们一起踏上这段旅程,解锁Java异常处理的秘密!
|
18天前
|
设计模式 Java 开发者
Java多线程编程的陷阱与解决方案####
本文深入探讨了Java多线程编程中常见的问题及其解决策略。通过分析竞态条件、死锁、活锁等典型场景,并结合代码示例和实用技巧,帮助开发者有效避免这些陷阱,提升并发程序的稳定性和性能。 ####
|
18天前
|
缓存 Java 开发者
Java多线程编程的陷阱与最佳实践####
本文深入探讨了Java多线程编程中常见的陷阱,如竞态条件、死锁和内存一致性错误,并提供了实用的避免策略。通过分析典型错误案例,本文旨在帮助开发者更好地理解和掌握多线程环境下的编程技巧,从而提升并发程序的稳定性和性能。 ####
|
11天前
|
安全 算法 Java
Java多线程编程中的陷阱与最佳实践####
本文探讨了Java多线程编程中常见的陷阱,并介绍了如何通过最佳实践来避免这些问题。我们将从基础概念入手,逐步深入到具体的代码示例,帮助开发者更好地理解和应用多线程技术。无论是初学者还是有经验的开发者,都能从中获得有价值的见解和建议。 ####
|
11天前
|
Java 调度
Java中的多线程编程与并发控制
本文深入探讨了Java编程语言中多线程编程的基础知识和并发控制机制。文章首先介绍了多线程的基本概念,包括线程的定义、生命周期以及在Java中创建和管理线程的方法。接着,详细讲解了Java提供的同步机制,如synchronized关键字、wait()和notify()方法等,以及如何通过这些机制实现线程间的协调与通信。最后,本文还讨论了一些常见的并发问题,例如死锁、竞态条件等,并提供了相应的解决策略。
32 3
|
16天前
|
开发框架 安全 Java
Java 反射机制:动态编程的强大利器
Java反射机制允许程序在运行时检查类、接口、字段和方法的信息,并能操作对象。它提供了一种动态编程的方式,使得代码更加灵活,能够适应未知的或变化的需求,是开发框架和库的重要工具。
34 2
|
21天前
|
Java 程序员
Java编程中的异常处理:从基础到高级
在Java的世界里,异常是程序运行中不可忽视的“惊喜”。它们可能突如其来,也可能悄无声息地潜伏。掌握异常处理的艺术,意味着你能够优雅地面对程序的不完美,并确保它即使在风雨飘摇中也能继续航行。本文将引导你理解Java异常的本质,探索捕获和处理这些异常的方法,并最终学会如何利用自定义异常为你的代码增添力量。
|
17天前
|
安全 Java 开发者
Java中的多线程编程:从基础到实践
本文深入探讨了Java多线程编程的核心概念和实践技巧,旨在帮助读者理解多线程的工作原理,掌握线程的创建、管理和同步机制。通过具体示例和最佳实践,本文展示了如何在Java应用中有效地利用多线程技术,提高程序性能和响应速度。
52 1
|
18天前
|
Java API 数据库
Java 反射机制:动态编程的 “魔法钥匙”
Java反射机制是允许程序在运行时访问类、方法和字段信息的强大工具,被誉为动态编程的“魔法钥匙”。通过反射,开发者可以创建更加灵活、可扩展的应用程序。
34 0
|
21天前
|
缓存 Java 开发者
Java中的多线程编程:从基础到进阶
在Java的世界中,多线程编程是一块不可或缺的拼图。它不仅提升了程序的效率和响应性,还让复杂任务变得井然有序。本文将带你领略多线程编程的魅力,从创建线程的基础操作到高级同步机制的应用,再到线程池的高效管理,我们将一步步揭开多线程编程的神秘面纱。无论你是初学者还是有一定经验的开发者,这篇文章都会为你提供新的视角和深入的理解。让我们一起探索Java多线程编程的世界,开启一段精彩的旅程吧!
37 0