首页 > 代码库 > [JAVA] 基于TCP的起重机运行模拟器
[JAVA] 基于TCP的起重机运行模拟器
1、客户端
1 package ClientMain; 2 3 import java.io.DataInputStream; 4 import java.io.DataOutputStream; 5 import java.io.IOException; 6 import java.net.InetAddress; 7 import java.net.Socket; 8 import java.text.SimpleDateFormat; 9 import java.util.Date; 10 import java.util.Scanner; 11 12 public class TcpClient { 13 public static void main(String[] args) throws IOException { 14 SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");// 设置日期格式 15 Socket s = null; 16 DataInputStream DataIn = null; 17 DataOutputStream DataOut = null; 18 try { 19 // s=new Socket(InetAddress.getByName("192.168.1.130"),8000); 20 s = new Socket("localhost", 8000); 21 DataIn = new DataInputStream(s.getInputStream()); 22 DataOut = new DataOutputStream(s.getOutputStream()); 23 System.out.println("连接成功"); 24 @SuppressWarnings("resource") 25 Scanner keyIn = new Scanner(System.in); 26 while (keyIn.hasNext()) { 27 String c = keyIn.nextLine(); 28 System.out.println("输入命令为: " + c); 29 if (c.length() == 0) 30 continue; 31 char inputchar = c.charAt(0);// 输入命令取字符串的第一个 32 switch (inputchar) { 33 case ‘a‘: 34 DataOut.writeByte(inputchar); 35 System.out.println(df.format(new Date()) + " : 执行大车前移命令");// 服务器日志信息 36 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 37 break;// 大车前移命令 38 case ‘b‘: 39 DataOut.writeByte(inputchar); 40 System.out.println(df.format(new Date()) + " : 执行大车后移命令");// 服务器日志信息 41 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 42 break;// 大车后移命令 43 case ‘c‘: 44 DataOut.writeByte(inputchar); 45 System.out.println(df.format(new Date()) + " : 执行大车停止命令");// 服务器日志信息 46 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 47 break;// 大车停止命令 48 case ‘d‘: 49 DataOut.writeByte(inputchar); 50 System.out.println(df.format(new Date()) + " : 执行小车前移命令");// 服务器日志信息 51 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 52 break;// 小车前移命令 53 case ‘e‘: 54 DataOut.writeByte(inputchar); 55 System.out.println(df.format(new Date()) + " : 执行小车后移命令");// 服务器日志信息 56 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 57 break;// 小车后移命令 58 case ‘f‘: 59 DataOut.writeByte(inputchar); 60 System.out.println(df.format(new Date()) + " : 执行小车停止命令");// 服务器日志信息 61 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 62 break;// 小车停止命令 63 case ‘g‘: 64 DataOut.writeByte(inputchar); 65 System.out.println(df.format(new Date()) + " : 执行吊钩上移命令");// 服务器日志信息 66 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 67 break;// 吊钩上移命令 68 case ‘h‘: 69 DataOut.writeByte(inputchar); 70 System.out.println(df.format(new Date()) + " : 执行吊钩下移命令");// 服务器日志信息 71 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 72 break;// 吊钩下移命令 73 case ‘i‘: 74 DataOut.writeByte(inputchar); 75 System.out.println(df.format(new Date()) + " : 执行吊钩停止命令");// 服务器日志信息 76 System.out.println("服务器返回数据: " + (char) DataIn.readByte()); 77 break;// 吊钩停止命令 78 case ‘j‘: 79 DataOut.writeByte(inputchar); 80 System.out.println(df.format(new Date()) + " : 执行获取大车位置命令");// 服务器日志信息 81 System.out.println("服务器返回数据: " + (char) DataIn.readByte() 82 + (char) DataIn.readByte() 83 + (char) DataIn.readByte() 84 + (char) DataIn.readByte() 85 + (char) DataIn.readByte() 86 + (char) DataIn.readByte()); 87 break;// 获取大车位置 88 case ‘k‘: 89 DataOut.writeByte(inputchar); 90 System.out.println(df.format(new Date()) + " : 执行获取小车位置命令");// 服务器日志信息 91 System.out.println("服务器返回数据: " + (char) DataIn.readByte() 92 + (char) DataIn.readByte() 93 + (char) DataIn.readByte() 94 + (char) DataIn.readByte() 95 + (char) DataIn.readByte() 96 + (char) DataIn.readByte()); 97 break;// 获取小车位置 98 case ‘l‘: 99 DataOut.writeByte(inputchar);100 System.out.println(df.format(new Date()) + " : 执行获取吊钩位置命令");// 服务器日志信息101 System.out.println("服务器返回数据: " + (char) DataIn.readByte()102 + (char) DataIn.readByte()103 + (char) DataIn.readByte()104 + (char) DataIn.readByte()105 + (char) DataIn.readByte()106 + (char) DataIn.readByte());107 break;// 获取吊钩位置108 case ‘m‘:109 DataOut.writeByte(inputchar);110 System.out.println(df.format(new Date()) + " : 执行获取大车速度命令");// 服务器日志信息111 System.out.println("服务器返回数据: " + (char) DataIn.readByte()112 + (char) DataIn.readByte()113 + (char) DataIn.readByte());114 break;// 获取大车速度115 case ‘n‘:116 DataOut.writeByte(inputchar);117 System.out.println(df.format(new Date()) + " : 执行获取小车速度命令");// 服务器日志信息118 System.out.println("服务器返回数据: " + (char) DataIn.readByte()119 + (char) DataIn.readByte()120 + (char) DataIn.readByte());121 break;// 获取小车速度122 case ‘o‘:123 DataOut.writeByte(inputchar);124 System.out.println(df.format(new Date()) + " : 执行获取吊钩速度命令");// 服务器日志信息125 System.out.println("服务器返回数据: " + (char) DataIn.readByte()126 + (char) DataIn.readByte()127 + (char) DataIn.readByte());128 break;// 获取吊钩速度129 case ‘p‘:130 DataOut.writeByte(inputchar);131 System.out.println(df.format(new Date()) + " : 执行获取重物重量命令");// 服务器日志信息132 System.out.println("服务器返回数据: " + (char) DataIn.readByte()133 + (char) DataIn.readByte()134 + (char) DataIn.readByte()135 + (char) DataIn.readByte()136 + (char) DataIn.readByte()137 + (char) DataIn.readByte());138 break;// 获取重物重量139 case ‘q‘:140 DataOut.writeByte(inputchar);141 System.out.println(df.format(new Date())142 + " : 执行获取机器本次工作时间命令");// 服务器日志信息143 System.out.println("服务器返回数据: " + (char) DataIn.readByte()144 + (char) DataIn.readByte()145 + (char) DataIn.readByte()146 + (char) DataIn.readByte()147 + (char) DataIn.readByte()148 + (char) DataIn.readByte());149 break;// 获取机器本次工作时间150 case ‘r‘:151 DataOut.writeByte(inputchar);152 System.out.println(df.format(new Date())153 + " : 执行获取机器总工作次数命令");// 服务器日志信息154 System.out.println("服务器返回数据: " + (char) DataIn.readByte()155 + (char) DataIn.readByte()156 + (char) DataIn.readByte()157 + (char) DataIn.readByte()158 + (char) DataIn.readByte()159 + (char) DataIn.readByte());160 break;// 获取机器总工作次数161 case ‘s‘:// [留待以后扩展]162 DataOut.writeByte(inputchar);163 System.out.println(df.format(new Date())164 + " : 执行获取机器工作状态命令");// 服务器日志信息165 break;// 获取机器工作状态166 default:167 System.out.println(df.format(new Date()) + " : 输入命令有误！");// 服务器日志信息168 break;// 错误操作169 }170 }171 DataIn.close();172 DataOut.close();173 s.close();174 } catch (IOException e) {175 // TODO Auto-generated catch block176 e.printStackTrace();177 }178 DataIn.close();179 DataOut.close();180 s.close();181 }182 }
2、服务器
1 package ServerMain; 2 3 import java.awt.Graphics2D; 4 5 public class Qzj { 6 public static final int GO = 1, BACK = -1, STOP = 0;// 3种运动状态 7 public Car big, small, hook;// 声明大车，小车和吊钩 8 public int weight;// 称重重量[0-99999kg] 9 public int all_work_times;// 总工作次数[0-99999次] 10 public int this_time;// 本次工作时长[0-99999分钟] 11 public int work_state;// 机器工作状态[留待] 12 13 Qzj() {// 这里偷下懒，一口气把所有参数写进来太麻烦干脆直接在这里修改吧 14 big = new Car(5000, 5, STOP, 0, 10000, 500, 9500, 8);// 大车初始位置为50米处，速度为5dm/s,停止状态，没有警报，轨道100m,左右限位，最大速度为8dm/s 15 small = new Car(100, 2, STOP, 0, 2000, 100, 1900, 5); 16 hook = new Car(0, -2, STOP, 0, 1000, 50, 950, 4); 17 weight = new java.util.Random().nextInt() % 100000; 18 all_work_times = new java.util.Random().nextInt() % 100000; 19 this_time = new java.util.Random().nextInt() % 100000; 20 work_state = 0; 21 22 Thread t1 = new Thread(big); 23 Thread t2 = new Thread(small); 24 Thread t3 = new Thread(hook); 25 26 t1.start(); 27 t2.start(); 28 t3.start(); 29 } 30 31 public class Car implements Runnable { 32 public int position;// 当前车的位置0-99999cm 33 public int speed;// 当前车的速度0-99dm/s 34 public int state;// 当前车的运动状态[GO,BACK,STOP] 35 public int warn;// 当前车是否有限位报警[留待] 36 public int length, limit_Lposition, limit_Rposition, limit_speed;// 轨道长度，左限位，右限位[cm]，限速[dm/s] 37 38 Car(int pos, int spe, int sta, int war, int len, int limit_Lpos, 39 int limit_Rpos, int limit_spe) { 40 position = pos; 41 speed = spe; 42 state = sta; 43 warn = war; 44 length = len; 45 limit_Lposition = limit_Lpos; 46 limit_Rposition = limit_Rpos; 47 limit_speed = limit_spe; 48 }// 构造函数 49 50 //将信息显示到屏幕上 51 public void showText(Graphics2D gg,int x,int y) { 52 gg.drawString("$: 实时信息---位置: "+position+" cm, 速度: "+speed+" dm/s, 状态: "+state+" , 警报: "+warn+" , 轨长: "+length+" cm, 左限位: "+limit_Lposition+" cm, 右限位: "+limit_Rposition+" cm, 限速"+limit_speed+" dm/s",x,y); 53 } 54 // //获取参数函数系 55 56 void setPos(int pos) { 57 position = pos; 58 } 59 60 void setSpe(int spe) { 61 speed = spe; 62 } 63 64 void setSta(int sta) { 65 state = sta; 66 } 67 68 void setWar(int war) { 69 warn = war; 70 } 71 72 void setLen(int len) { 73 length = len; 74 } 75 76 void setLimit_Lpos(int limit_Lpos) { 77 limit_Lposition = limit_Lpos; 78 } 79 80 void setLimit_Rpos(int limit_Rpos) { 81 limit_Rposition = limit_Rpos; 82 } 83 84 void setLimit_spe(int limit_spe) { 85 limit_speed = limit_spe; 86 } 87 88 // // 89 90 // //设置参数函数系 91 int getPos() { 92 return position; 93 } 94 95 int getSpe() { 96 return speed; 97 } 98 99 int getSta() {100 return state;101 }102 103 int getWar() {104 return warn;105 }106 107 int getLen() {108 return length;109 }110 111 int getLimit_Lpos() {112 return limit_Lposition;113 }114 115 int getLimit_Rpos() {116 return limit_Rposition;117 }118 119 int getLimit_spe() {120 return limit_speed;121 }122 123 // //124 @Override125 public void run() {// 车运动的线程函数126 while (true) {127 switch (state) {// 运动处理128 case GO:129 position += speed*10;//单位转换，因为速度是dm/s其他的是cm为单位130 break;131 case BACK:132 position -= speed*10;//单位转换133 break;134 case STOP:135 break;136 default:137 break;138 }139 // 限位报警处理140 if (position > limit_Rposition) {// 超出右限位，停在右限位141 position = limit_Rposition;142 state = STOP;143 } else if (position < limit_Lposition) {// 超出左限位，停在左限位144 position = limit_Lposition;145 state = STOP;146 }147 // 等待时间148 try {149 Thread.sleep(500);150 } catch (InterruptedException e) {151 // TODO Auto-generated catch block152 e.printStackTrace();153 }154 }155 }156 }157 }
>_<" 起重机类，这里将大车，小车，勾用类Car来实现，然后分别声明（因为他们有相似点）；至于起重机其他参数就在QZJ的类里面声明~
1 package ServerMain; 2 3 import java.io.DataInputStream; 4 import java.io.DataOutputStream; 5 import java.io.IOException; 6 import java.net.ServerSocket; 7 import java.net.Socket; 8 import java.text.SimpleDateFormat; 9 import java.util.Date; 10 11 public class TcpServer { 12 13 public static Qzj qzj = new Qzj();// 实例化一个起重机的类 14 public static SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");// 设置日期格式 15 // System.out.println(df.format(new Date()));// new Date()为获取当前系统时间 16 public static ServerSocket server; 17 public static Socket s = null; 18 public static DataOutputStream dataOut = null; 19 public static DataInputStream dataIn = null; 20 21 public TcpServer() throws IOException{ 22 server = new ServerSocket(8000); 23 getandsend mes = new getandsend(); 24 Thread t1 = new Thread(mes); 25 t1.start(); 26 } 27 28 public class getandsend implements Runnable { 29 public void run() { 30 while (true) { 31 try { 32 s = server.accept(); 33 dataOut = new DataOutputStream(s.getOutputStream()); 34 dataIn = new DataInputStream(s.getInputStream()); 35 while (true) { 36 Byte c = dataIn.readByte(); 37 switch (c) { 38 case ‘a‘: 39 dataOut.writeByte(‘a‘); 40 qzj.big.state=Qzj.GO; 41 System.out.println(df.format(new Date()) 42 + " : 执行大车前移命令");// 服务器日志信息 43 break;// 大车前移命令 44 case ‘b‘: 45 dataOut.writeByte(‘b‘); 46 qzj.big.state=Qzj.BACK; 47 System.out.println(df.format(new Date()) 48 + " : 执行大车后移命令");// 服务器日志信息 49 break;// 大车后移命令 50 case ‘c‘: 51 dataOut.writeByte(‘c‘); 52 qzj.big.state=Qzj.STOP; 53 System.out.println(df.format(new Date()) 54 + " : 执行大车停止命令");// 服务器日志信息 55 break;// 大车停止命令 56 case ‘d‘: 57 dataOut.writeByte(‘d‘); 58 qzj.small.state=Qzj.GO; 59 System.out.println(df.format(new Date()) 60 + " : 执行小车前移命令");// 服务器日志信息 61 break;// 小车前移命令 62 case ‘e‘: 63 dataOut.writeByte(‘e‘); 64 qzj.small.state=Qzj.BACK; 65 System.out.println(df.format(new Date()) 66 + " : 执行小车后移命令");// 服务器日志信息 67 break;// 小车后移命令 68 case ‘f‘: 69 dataOut.writeByte(‘f‘); 70 qzj.small.state=Qzj.STOP; 71 System.out.println(df.format(new Date()) 72 + " : 执行小车停止命令");// 服务器日志信息 73 break;// 小车停止命令 74 case ‘g‘: 75 dataOut.writeByte(‘g‘); 76 qzj.hook.state=Qzj.GO; 77 System.out.println(df.format(new Date()) 78 + " : 执行吊钩上移命令");// 服务器日志信息 79 break;// 吊钩上移命令 80 case ‘h‘: 81 dataOut.writeByte(‘h‘); 82 qzj.hook.state=Qzj.BACK; 83 System.out.println(df.format(new Date()) 84 + " : 执行吊钩下移命令");// 服务器日志信息 85 break;// 吊钩下移命令 86 case ‘i‘: 87 dataOut.writeByte(‘i‘); 88 qzj.hook.state=Qzj.STOP; 89 System.out.println(df.format(new Date()) 90 + " : 执行吊钩停止命令");// 服务器日志信息 91 break;// 吊钩停止命令 92 case ‘j‘: 93 sendstring(dataOut, qzj.big.getPos(), 6, ‘j‘); 94 System.out.println(df.format(new Date()) 95 + " : 执行获取大车位置命令");// 服务器日志信息 96 break;// 获取大车位置 97 case ‘k‘: 98 sendstring(dataOut, qzj.small.getPos(), 6, ‘k‘); 99 System.out.println(df.format(new Date())100 + " : 执行获取小车位置命令");// 服务器日志信息101 break;// 获取小车位置102 case ‘l‘:103 sendstring(dataOut, qzj.hook.getPos(), 6, ‘l‘);104 System.out.println(df.format(new Date())105 + " : 执行获取吊钩位置命令");// 服务器日志信息106 break;// 获取吊钩位置107 case ‘m‘:108 sendstring(dataOut, qzj.big.getSpe(), 3, ‘m‘);109 System.out.println(df.format(new Date())110 + " : 执行获取大车速度命令");// 服务器日志信息111 break;// 获取大车速度112 case ‘n‘:113 sendstring(dataOut, qzj.small.getSpe(), 3, ‘n‘);114 System.out.println(df.format(new Date())115 + " : 执行获取小车速度命令");// 服务器日志信息116 break;// 获取小车速度117 case ‘o‘:118 sendstring(dataOut, qzj.hook.getSpe(), 3, ‘o‘);119 System.out.println(df.format(new Date())120 + " : 执行获取吊钩速度命令");// 服务器日志信息121 break;// 获取吊钩速度122 case ‘p‘:123 sendstring(dataOut, qzj.weight, 6, ‘p‘);124 System.out.println(df.format(new Date())125 + " : 执行获取重物重量命令");// 服务器日志信息126 break;// 获取重物重量127 case ‘q‘:128 sendstring(dataOut, qzj.this_time, 6, ‘q‘);129 System.out.println(df.format(new Date())130 + " : 执行获取机器本次工作时间命令");// 服务器日志信息131 break;// 获取机器本次工作时间132 case ‘r‘:133 sendstring(dataOut, qzj.all_work_times, 6, ‘r‘);134 System.out.println(df.format(new Date())135 + " : 执行获取机器总工作次数命令");// 服务器日志信息136 break;// 获取机器总工作次数137 case ‘s‘:// [留待以后扩展]138 sendstring(dataOut, qzj.work_state, 6, ‘s‘);139 System.out.println(df.format(new Date())140 + " : 执行获取机器工作状态命令");// 服务器日志信息141 break;// 获取机器工作状态142 default:143 break;// 错误操作144 }145 }146 } catch (IOException e) {147 }finally{148 try {149 dataOut.close();150 dataIn.close();151 s.close();152 } catch (IOException e) {153 e.printStackTrace();154 }155 }156 }157 }158 }159 160 // 将int类的data转换为i-1位字符串并加上c结尾发送出去函数161 private static void sendstring(DataOutputStream dataOut, int data, int i,162 char c) throws IOException {163 switch (i) {164 case 6:165 dataOut.writeByte((char) (data / 10000 + ‘0‘));166 data %= 10000;167 case 5:168 dataOut.writeByte((char) (data / 1000 + ‘0‘));169 data %= 1000;170 case 4:171 dataOut.writeByte((char) (data / 100 + ‘0‘));172 data %= 100;173 case 3:174 dataOut.writeByte((char) (data / 10 + ‘0‘));175 data %= 10;176 case 2:177 dataOut.writeByte((char) (data + ‘0‘));178 case 1:179 dataOut.writeByte(c);180 }181 }182 183 public static void main(String[] args) throws IOException {184 new TcpServer();185 }186 }
>_<" TCP服务器，负责接收客户端命令和处理命令~
1 package ServerMain; 2 3 4 import javax.swing.*; 5 import java.awt.*; 6 import java.io.IOException; 7 8 9 final class Draw extends JFrame implements Runnable { 10 11 public static TcpServer tcp; 12 13 Draw() throws HeadlessException, IOException { 14 super(); 15 Container container = getContentPane(); 16 container.add(canvas, BorderLayout.CENTER);//把canvas加入中间 17 pack(); 18 tcp=new TcpServer();//使命并实例化一个TCP服务器并启动 19 } 20 21 private final static JComponent canvas = new JComponent() { 22 protected void paintComponent(Graphics g) { 23 super.paintComponent(g); 24 drawQZJ(g); 25 drawText(g); 26 } 27 28 //http://www.weixueyuan.net/view/6074.html Graphics资料 29 //绘制起重机3维图像 30 private int a=10,b=90,wid=600,len=380;//矩形框的位置和大小 31 public void drawQZJ(Graphics g){ 32 Graphics2D gg=(Graphics2D)g; 33 gg.setColor(Color.BLUE); 34 gg.fillRect(0 , 0 , 800 , 480); 35 gg.setColor(Color.YELLOW); 36 gg.fillRect(a, b , wid, len); 37 gg.setColor(Color.BLACK); 38 gg.drawRect(a, b , wid, len); 39 Stroke stroke=new BasicStroke(2.0f);//设置线宽为2.0 40 gg.setStroke(stroke); 41 gg.setColor(Color.BLACK); 42 //最长横梁边距为15，间距为100 43 gg.drawLine(a+15, b+15,wid+a-15, b+15); 44 gg.drawLine(a+15, b+115,wid+a-15, b+115); 45 //画大车，将位置经过比例运算展现，这里位置默认为大车中间位置，所以前后伸长25 46 gg.drawLine(a+15-25+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(), b+5,a+15-25+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(), b+125); 47 gg.drawLine(a+15+25+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(), b+5,a+15+25+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(), b+125); 48 //画小车 49 gg.setColor(Color.RED); 50 gg.drawLine(a+15-25+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen()-10, b+15+tcp.qzj.small.getPos()*100/tcp.qzj.small.getLen(),a+15+25+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen()+10, b+15+tcp.qzj.small.getPos()*100/tcp.qzj.small.getLen()); 51 //画勾 52 gg.setColor(Color.BLACK); 53 gg.drawLine(a+15,b+175,wid+a-15,b+175);//横轨 54 stroke=new BasicStroke(1.0f);//设置线宽为1.0 55 gg.setStroke(stroke); 56 gg.drawRect(a+15-4+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),b+175-4,8,6);//滑块8X6 57 gg.drawLine(a+15+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),b+175+2,a+15+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),tcp.qzj.hook.getPos()*170/tcp.qzj.hook.getLen()+b+175+2);//中间的线 58 gg.fillRect(a+15-3+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),tcp.qzj.hook.getPos()*170/tcp.qzj.hook.getLen()+b+175+2,7,6);//下面的小方块7X6 59 gg.drawLine(a+15+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),tcp.qzj.hook.getPos()*170/tcp.qzj.hook.getLen()+b+175+2+6,a+15+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),tcp.qzj.hook.getPos()*170/tcp.qzj.hook.getLen()+b+175+2+6+3);//下面是画最下面的勾 60 gg.drawRect(a+15-6+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),tcp.qzj.hook.getPos()*170/tcp.qzj.hook.getLen()+b+175+2+6+3,12,6);//负载12X6 61 gg.setColor(Color.YELLOW); 62 gg.fillRect(a+15-6-1+tcp.qzj.big.getPos()*(wid-30)/tcp.qzj.big.getLen(),tcp.qzj.hook.getPos()*170/tcp.qzj.hook.getLen()+b+175+2+6+3-1,7,4);//画一个黄色的矩形将上面的矩形变成一个勾 63 64 } 65 66 //显示起重机信息 67 private void drawText(Graphics g) { 68 Graphics2D gg=(Graphics2D)g; 69 gg.setColor(Color.BLACK); 70 //右边上部分显示起重机的整体运动实时参数 71 gg.drawString("$ 称重重量: "+tcp.qzj.weight+" [kg]",620,100);//weight 72 gg.drawString("$ 总工作次数: "+tcp.qzj.all_work_times+" [次]",620,120);//all_work_times 73 gg.drawString("$ 本次工作时长: "+tcp.qzj.this_time+" [分钟]",620,140);//this_time 74 gg.drawString("$ 机器工作状态: "+tcp.qzj.work_state+" [留待]",620,160);//work_state 75 gg.drawLine(620, 165, 760, 165); 76 //右下部分显示客户端TCP发送过来的控制命令 77 gg.drawString("$ 大车前移命令: a",620,180); 78 gg.drawString("$ 大车后移命令: b",620,195); 79 gg.drawString("$ 大车停止命令: c",620,210); 80 gg.drawString("$ 小车前移命令: d",620,225); 81 gg.drawString("$ 小车后移命令: e",620,240); 82 gg.drawString("$ 小车停止命令: f",620,255); 83 gg.drawString("$ 吊钩上移命令: g",620,270); 84 gg.drawString("$ 吊钩下移命令: h",620,285); 85 gg.drawString("$ 吊钩停止命令: i",620,300); 86 gg.drawString("$ 获取大车位置: j",620,315); 87 gg.drawString("$ 获取小车位置: k",620,330); 88 gg.drawString("$ 获取吊钩位置: l",620,345); 89 gg.drawString("$ 获取大车速度: m",620,360); 90 gg.drawString("$ 获取小车速度: n",620,375); 91 gg.drawString("$ 获取吊钩速度: o",620,390); 92 gg.drawString("$ 获取重物重量: p",620,405); 93 gg.drawString("$ 本次工作时间: q",620,420); 94 gg.drawString("$ 总的工作次数: r",620,435); 95 gg.drawString("$ 获取工作状态: s",620,450); 96 //上面一部分显示实时信息 97 gg.drawString("$----嵌入式操作系统Java模拟机,第1.0版,2014-9-18-3:15----$",230,20);//标题 98 tcp.qzj.big.showText(gg, 10, 50); 99 tcp.qzj.small.showText(gg, 10, 65); 100 tcp.qzj.hook.showText(gg, 10, 80); 101 102 }103 104 };//canvas105 106 @Override107 public void run() {//每隔一定时间进行绘制108 while(true){109 canvas.repaint(); 110 try {111 Thread.sleep(100);112 }catch (Exception e){}113 }114 }115 116 public static void main(String[] args) throws IOException {117 //绘图窗口实例化并启动刷新进程118 Draw show=new Draw();119 show.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);120 show.setSize(800,518);121 show.setVisible(true);122 Thread t2 = new Thread(show);123 t2.start();124 }125 }
>_<" 负责绘制模拟起重机运动界面，实现模拟起重机的功能~
3、效果展示
>_<" 最终实现客户端在consoles里输入相应命令，然后通过TCP把数据传输至网络另一端的服务器，另一端的服务器根据不同的命令做出相应的回应及控制动作~这里运行的时候要先运行服务器部分，是draw文件，不是tcpserver文件，因为总的启动函数在draw中，客户端就直接运行但是要在服务器之后~(虽然这是最基本的知识了，但是还是要说一下~),此外每次调试的时候要先关闭客户端，再关闭服务器，如果一切正常启动服务器有错误，就检查一下consoles里是否服务器已经关闭(因为每次只能开一个服务器,没关闭上一个，端口就没有释放所以就报错)
[图1 服务器模拟端界面]
[图2 客户端Console部分]
[图3 服务器端consoles部分]
4、通信协议
[JAVA] 基于TCP的起重机运行模拟器
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。